fix complete email id mismatch

shared/workspaces/test/test_capability_engine.py

@@ -13,9 +13,10 @@ Tests for CapabilityEngine
 """
 
 
-@pytest.mark.usefixtures("mock_capability_execution", "mock_capability_engine", "mock_workflow_service")
+@pytest.mark.usefixtures(
+    "mock_capability_execution", "mock_capability_engine", "mock_workflow_service"
+)
 class TestCapabilityEngine:
-
     @pytest.mark.filterwarnings("ignore::sqlalchemy.exc.SAWarning")
     def test_load_engine(
         self,
@@ -28,25 +29,25 @@ class TestCapabilityEngine:
         assert engine.execution == mock_capability_execution
 
     @pytest.mark.filterwarnings("ignore::sqlalchemy.exc.SAWarning")
-    def test_execute(
-            self,
-            mock_capability_engine: CapabilityEngine
-    ):
-        assert mock_capability_engine.execution.steps == 'prepare-and-run-workflow null\nawait-workflow'
+    def test_execute(self, mock_capability_engine: CapabilityEngine):
+        assert (
+            mock_capability_engine.execution.steps
+            == "prepare-and-run-workflow null\nawait-workflow"
+        )
         assert mock_capability_engine.execution.current_step == 0
         steps = mock_capability_engine.execution.steps
         step = CapabilitySequence.from_str(steps)[0]
-        assert step.step_value == 'null'
+        assert step.step_value == "null"
         # Execute is confirmed as getting called with the correct steps at this point.
         # TODO: The following line can't be run without mocked steps, but this method also belongs to steps so...
         # assert step.execute.call_count == 1
 
     @pytest.mark.filterwarnings("ignore::sqlalchemy.exc.SAWarning")
     def test_submit_workflow_request(
-            self,
-            mock_capability_execution: CapabilityExecution,
-            mock_workflow_service: WorkflowService,
-            mock_workflow_requests: WorkflowRequest
+        self,
+        mock_capability_execution: CapabilityExecution,
+        mock_workflow_service: WorkflowService,
+        mock_workflow_requests: WorkflowRequest,
     ):
         # assert mock_workflow_service.create_workflow_request(workflow="null", argument="-g") == mock_workflow_requests[0]
         pass

shared/workspaces/workspaces/capability/services/capability_service.py

@@ -132,5 +132,5 @@ class CapabilityService(CapabilityServiceIF):
         logger.info(f"RECEIVED CAPABILITY MESSAGE: {message}")
 
         subject = message["subject"]
-        request = self.capability_info.lookup_capability_request(subject["id"])
+        request = self.capability_info.lookup_capability_request(subject["capability_request_id"])
         self.notify.notify_complete(request)