feat: Add running user API token

Author: Alan Christie

tests/wapi_adapter.py

@@ -241,8 +241,8 @@ def create_running_workflow(
         running_workflow_id: str = _RUNNING_WORKFLOW_ID_FORMAT.format(id=next_id)
         record = {
             "name": "test-running-workflow",
-            "user_id": user_id,
-            "user_api_token": "123456789",
+            "running_user": user_id,
+            "running_user_api_token": "123456789",
             "done": False,
             "success": False,
             "workflow": {"id": workflow_id},

workflow/workflow_abc.py

@@ -105,8 +105,8 @@ def get_running_workflow(
         # Should return:
         # {
         #       "name": "workflow-name",
-        #       "user_id": "alan",
-        #       "user_api_token": "123456789",
+        #       "running_user": "alan",
+        #       "running_user_api_token": "123456789",
         #       "done": False,
         #       "success": false,
         #       "error": None,

workflow/workflow_engine.py

@@ -109,8 +109,8 @@ def _handle_workflow_start_message(self, r_wfid: str) -> None:
         _LOGGER.debug(
             "API.get_running_workflow(%s) returned: -\n%s", r_wfid, str(rwf_response)
         )
-        assert "user_id" in rwf_response
-        launching_user_name: str = rwf_response["user_id"]
+        assert "running_user" in rwf_response
+        launching_user_name: str = rwf_response["running_user"]
         # Now get the workflow definition (to get all the steps)
         wfid = rwf_response["workflow"]["id"]
         wf_response, _ = self._wapi_adapter.get_workflow(workflow_id=wfid)
@@ -155,7 +155,7 @@ def _handle_workflow_start_message(self, r_wfid: str) -> None:
             application_id=DM_JOB_APPLICATION_ID,
             name=first_step_name,
             launching_user_name=launching_user_name,
-            launching_user_api_token=rwf_response["user_api_token"],
+            launching_user_api_token=rwf_response["running_user_api_token"],
             specification=json.loads(first_step["specification"]),
             specification_variables=variables,
             running_workflow_id=r_wfid,
@@ -279,8 +279,8 @@ def _handle_pod_message(self, msg: PodMessage) -> None:
                         project_id=project_id,
                         application_id=DM_JOB_APPLICATION_ID,
                         name=next_step_name,
-                        launching_user_name=rwf_response["user_id"],
-                        launching_user_api_token=rwf_response["user_api_token"],
+                        launching_user_name=rwf_response["running_user"],
+                        launching_user_api_token=rwf_response["running_user_api_token"],
                         specification=json.loads(next_step["specification"]),
                         specification_variables=variables,
                         running_workflow_id=r_wfid,