Skip to content
Snippets Groups Projects

Fix ingest seci

Merged Charlotte Hausman requested to merge fix_ingest_seci into main
1 file
+ 1
1
Compare changes
  • Side-by-side
  • Inline
@@ -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:
Loading