Fix ingest seci

apps/cli/executables/go/iiwf_trigger/pkg/ingest/get_info.go

@@ -26,6 +26,7 @@ import (
 	"io"
 	"io/ioutil"
 	"net/http"
+	"net/url"
 	"path/filepath"
 )
 
@@ -38,6 +39,7 @@ type CapoInput struct {
 	CapoProfile string
 }
 
+//checkError
 /**
  * Check if an error happened and panic on it if so
  *
@@ -79,7 +81,7 @@ func GetCalibrationLocator(imgSetPath string, input CapoInput) string {
 	imgSet := filepath.Base(imgSetPath)
 
 	// Make the REST call
-	lookupUrl := locatorEndpoint + imgSet
+	lookupUrl := locatorEndpoint + url.QueryEscape(imgSet)
 	resp, err := http.Get(lookupUrl)
 	checkError(err)
 

apps/cli/executables/pexable/ingest_envoy/ingest_envoy/ingest.py

@@ -160,7 +160,7 @@ def send_aat_image_message(parameters: dict, ingest_type: Union[IngestType, VLAS
 
     if response.status_code != http.HTTPStatus.OK:
         logger.warning(
-            f"WARNING: Failed to send image ingestion complete to archive for image associated with"
+            f"WARNING: Failed to send image ingestion complete to archive for image associated with "
             f"calibration {parameters['calSpl']} and project {parameters['project']}."
             f" Please set off the index manually!"
         )

shared/workspaces/workspaces/workflow/message_architect.py

@@ -278,7 +278,12 @@ class ArchiveMessageArchitect(MessageArchitectIF):
         template = self.get_message_template(msg_type)
         template = template.copy()
         # not using full request for AAT/VLASS messages, increased size caused VLASS message handling issues
-        template["subject"] = f"WS workflow request #{self.request.workflow_request_id}"
+        # image indexing is based on project not request id, use different subject
+        template["subject"] = (
+            f"WS workflow triggering indexer for {self.project}"
+            if self.key == "ingestor.images"
+            else f"WS workflow request #{self.request.workflow_request_id}"
+        )
         template["routing_key"] = self.key
 
         if "vlass" in msg_type and "update" not in msg_type: