WS-1082: Forgotten communications bits

shared/workspaces/workspaces/workflow/message_architect.py

@@ -118,6 +118,16 @@ archive_msg_templates = DictView(
             "message": "seci complete",
             "status": "complete",
         },
+        "coarse_failed": {
+            "application": "workflow",
+            "message": "coarse failed",
+            "status": "failed",
+        },
+        "coarse_complete": {
+            "application": "workflow",
+            "message": "coarse complete",
+            "status": "complete",
+        },
         "do_not_calibrate": {
             "application": "qa-script",
             "logData": {

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

@@ -962,7 +962,7 @@ class WorkflowMessageHandler:
             logger.info(f"SENDING FAILED COARSE CUBE MESSAGE to VLASS Manager for request #{wf_id}!")
             routing_key = f"ws-workflow.coarse_cube.{wf_id}"
             cube_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
-                "coarse_cube_failed"
+                "coarse_failed"
             )
             self.archive_messenger.send_message(**cube_msg)
 
@@ -983,7 +983,7 @@ class WorkflowMessageHandler:
             logger.info(f"SENDING COARSE CUBE COMPLETE MESSAGE to VLASS Manager for request #{wf_id}!")
             routing_key = f"ws-workflow.coarse_cube.{wf_id}"
             cube_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
-                "coarse_cube_complete"
+                "coarse_complete"
             )
             self.archive_messenger.send_message(**cube_msg)