feat: Add get_running_workflow_step_output_values_for_output() to API

Author: Alan Christie

tests/test_test_api_adapter.py

@@ -443,6 +443,21 @@ def test_get_running_workflow_step_by_name():
     assert response["id"] == rwfs_id
 
 
+def test_basic_get_running_workflow_step_output_values_for_output_when_step_unknown():
+    # Arrange
+    utaa = UnitTestWorkflowAPIAdapter()
+
+    # Act
+    response, _ = utaa.get_running_workflow_step_output_values_for_output(
+        running_workflow_step_id="r-workflow-step-00000000-0000-0000-0000-000000000001",
+        output="outputFile",
+    )
+
+    # Assert
+    assert "outputs" in response
+    assert len(response["outputs"]) == 0
+
+
 def test_basic_realise():
     # Arrange
     utaa = UnitTestWorkflowAPIAdapter()

tests/wapi_adapter.py

@@ -390,7 +390,7 @@ def get_running_workflow_steps(self, *, running_workflow_id: str) -> dict[str, A
                 steps.append(item)
         return {"count": len(steps), "running_workflow_steps": steps}
 
-    def get_running_workflow_step_outputs(
+    def get_running_workflow_step_output_values_for_output(
         self, *, running_workflow_step_id: str, output: str
     ) -> tuple[dict[str, Any], int]:
         del running_workflow_step_id

workflow/workflow_abc.py

@@ -349,16 +349,16 @@ def get_job(
         # If not present an empty dictionary should be returned.
 
     @abstractmethod
-    def get_running_workflow_step_outputs(
+    def get_running_workflow_step_output_values_for_output(
         self, *, running_workflow_step_id: str, output: str
     ) -> tuple[dict[str, Any], int]:
-        """Gets the set of outputs for the output variable of a given step.
+        """Gets the set of outputs generated for the output variable of a given step.
         The step must have stopped for this to return any meaningful value.
         Returned files might also include paths that are relative to the
         Step's instance directory."""
         # Should return a (possibly empty) list of paths and filenames:
         # {
-        #   "outputs": ["file1.sdf", "file2.sdf"]
+        #   "outputs": ["dir/file1.sdf", "dir/file2.sdf"]
         # }
 
     @abstractmethod