add image caching message handeling

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

@@ -979,6 +979,14 @@ class WorkflowMessageHandler:
             )
             self.archive_messenger.send_message(**cal_msg)
 
+        if wf_request.workflow_name == ArchiveWorkflows.IMG_CACHE.value:
+            logger.debug(f"Sending failed image caching message to VLASS Manager for request #{wf_id}")
+            routing_key = f"ws-workflow.caching.{wf_id}"
+            caching_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
+                "vlass_caching_failed"
+            )
+            self.archive_messenger.send_message(**caching_msg)
+
     def send_archive_complete_event(self, **message: Dict):
         subject = message["subject"]
         wf_id = subject["workflow_request_id"]
@@ -1001,14 +1009,22 @@ class WorkflowMessageHandler:
             self.archive_messenger.send_message(**cube_msg)
 
         if wf_request.workflow_name == ArchiveWorkflows.QUICKLOOK.value:
-            logger.debug(f"Sending quicklook message to VLASS Manager for request #{wf_id}")
+            logger.debug(f"Sending quicklook message complete to VLASS Manager for request #{wf_id}")
             routing_key = f"ws-workflow.quicklook.{wf_id}"
             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}")
+            logger.debug(f"Sending calibration message complete to VLASS Manager for request #{wf_id}")
             routing_key = f"ws-workflow.calibration.{wf_id}"
+            cache_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
+                "vlass_caching_complete"
+            )
+            self.archive_messenger.send_message(**cache_msg)
+
+        if wf_request.workflow_name == ArchiveWorkflows.IMG_CACHE.value:
+            logger.debug(f"Sending image caching message complete to VLASS Manager for request #{wf_id}")
+            routing_key = f"ws-workflow.caching.{wf_id}"
             cal_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message(
                 "vlass_cal_complete"
             )