initial vlass calibration templates

shared/workspaces/workspaces/workflow/services/workflow_service.py

@@ -970,6 +970,14 @@ class WorkflowMessageHandler:
             ql_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message("ql_failed")
             self.archive_messenger.send_message(**ql_msg)
 
+        if wf_request.workflow_name == ArchiveWorkflows.VLASS_CAL.value:
+            logger.debug(f"Sending failed 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(
+                "vlass_cal_failed"
+            )
+            self.archive_messenger.send_message(**cal_msg)
+
     def send_archive_complete_event(self, **message: Dict):
         subject = message["subject"]
         wf_id = subject["workflow_request_id"]
@@ -997,6 +1005,14 @@ 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.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(
+                "vlass_cal_complete"
+            )
+            self.archive_messenger.send_message(**cal_msg)
+
     @staticmethod
     def clean_remote_workflow(request: WorkflowRequest):
         injector = CapoInjector(request)