Await QA

potential issue with analyst mailing list - waiting on outstanding helpdesk ticket

shared/workspaces/workspaces/capability/services/capability_engine.py

@@ -12,6 +12,8 @@ from workspaces.capability.services.interfaces import (
 from workspaces.system.schema import AbstractFile
 from workspaces.workflow.services.interfaces import WorkflowServiceIF
 
+from shared.messaging.messaging.router import Router
+
 logger = logging.getLogger(__name__)
 
 
@@ -24,10 +26,12 @@ class CapabilityEngine(CapabilityEngineIF):
         self,
         capability_info: CapabilityInfoIF,
         workflow_service: WorkflowServiceIF,
+        message_router: Router
     ):
         self.capability_info = capability_info
         self.workflow_service = workflow_service
         self.execution = None
+        self.message_router = message_router
 
     def load_engine(self, execution: CapabilityExecutionIF):
         """
@@ -96,3 +100,12 @@ class CapabilityEngine(CapabilityEngineIF):
         self.capability_info.save_execution(execution)
         transaction.commit()
         self.workflow_service.execute(workflow_request)
+
+    def step_complete(self, execution: CapabilityExecutionIF):
+        step_complete_msg = {
+            "service": "capability",
+            "routing_key": "capability",
+            "subject": execution.__json__(),
+            "type": "step-complete",
+        }
+        self.message_router.send_message(**step_complete_msg)