Skip to content
Snippets Groups Projects

initial vlass calibration templates

Merged Charlotte Hausman requested to merge vlass_calibration into main
@@ -1005,7 +1005,7 @@ class WorkflowMessageHandler:
ql_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message("ql_complete")
self.archive_messenger.send_message(**ql_msg)
if wf_request.workflow_name == ArchiveWorkflows.QUICKLOOK.value:
if wf_request.workflow_name == ArchiveWorkflows.VLASS_CAL.value:
logger.debug(f"Sending calibration message to VLASS Manager for request #{wf_id}")
routing_key = f"ws-workflow.calibration.{wf_id}"
cal_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
Loading