diff --git a/shared/workspaces/workspaces/workflow/services/workflow_service.py b/shared/workspaces/workspaces/workflow/services/workflow_service.py index 8711b765bcba7f6f8620f8be7087420f5c3a0b22..4af11ccf7975dca41c0299cd571641dffe70f5cc 100644 --- a/shared/workspaces/workspaces/workflow/services/workflow_service.py +++ b/shared/workspaces/workspaces/workflow/services/workflow_service.py @@ -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(