[arvados] created: 2.1.0-2940-g210f068ee

git repository hosting git at public.arvados.org
Mon Oct 3 19:50:18 UTC 2022


        at  210f068ee8ba5b6f56459ba2f14c86b59385b29b (commit)


commit 210f068ee8ba5b6f56459ba2f14c86b59385b29b
Author: Peter Amstutz <peter.amstutz at curii.com>
Date:   Mon Oct 3 15:49:46 2022 -0400

    19466: Add cwl_input and cwl_output to properties for workflow steps
    
    Arvados-DCO-1.1-Signed-off-by: Peter Amstutz <peter.amstutz at curii.com>

diff --git a/sdk/cwl/arvados_cwl/arvcontainer.py b/sdk/cwl/arvados_cwl/arvcontainer.py
index e9b58bc83..66fe143e0 100644
--- a/sdk/cwl/arvados_cwl/arvcontainer.py
+++ b/sdk/cwl/arvados_cwl/arvcontainer.py
@@ -91,6 +91,8 @@ class ArvadosContainer(JobBase):
         container_request["state"] = "Committed"
         container_request.setdefault("properties", {})
 
+        container_request["properties"]["cwl_input"] = self.joborder
+
         runtime_constraints = {}
 
         if runtimeContext.project_uuid:
@@ -437,6 +439,13 @@ class ArvadosContainer(JobBase):
 
             if container["output"]:
                 outputs = done.done_outputs(self, container, "/tmp", self.outdir, "/keep")
+
+            properties = record["properties"].copy()
+            properties["cwl_output"] = outputs
+            self.arvrunner.api.container_requests().update(
+                uuid=self.uuid,
+                body={"container_request": {"properties": properties}}
+            ).execute(num_retries=self.arvrunner.num_retries)
         except WorkflowException as e:
             # Only include a stack trace if in debug mode.
             # A stack trace may obfuscate more useful output about the workflow.

-----------------------------------------------------------------------


hooks/post-receive
-- 




More information about the arvados-commits mailing list