Skip to content
Snippets Groups Projects

Fixing post-ingestion message error

Merged Daniel Nemergut requested to merge ingest_obs_aat_message into main
2 unresolved threads
@@ -120,6 +120,16 @@ archive_msg_templates = DictView(
"status": "complete",
},
},
"obs_ingestion_complete": {
"application": "ingestor",
"message": "Observation Ingestion Complete",
"request": "observation",
"logData": {
"project_code": None,
"ingestion_type": "vlba",
"status": "complete",
},
},
"download_complete": {
"application": "workflow",
"download_url": None,
@@ -281,7 +291,7 @@ class ArchiveMessageArchitect(MessageArchitectIF):
# image indexing is based on project not request id, use different subject
template["subject"] = (
f"WS workflow triggering indexer for {self.project}"
if not self.request
if self.key in ["ingestor.images", "ingestion-complete.vlba"]
else f"WS workflow request #{self.request.workflow_request_id}"
)
template["routing_key"] = self.key
Loading