undo fast_step_cwl_load

MemVerge · Sep 21, 2023 · 8c46654 · 8c46654
1 parent 5e4fc51
commit 8c46654
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/cwl_airflow/extensions/cwldag.py b/cwl_airflow/extensions/cwldag.py
@@ -62,7 +62,7 @@ def __init__(
             task_id="CWLJobGatherer"
         ) if gatherer is None else gatherer
         self.workflow_tool = embed_all_runs(
-            self.workflow_tool, cwl_args=kwargs["default_args"]["cwl"])
+            self.workflow_tool, cwl_args=kwargs["default_args"]["cwl"], location=self.workflow)
         self.__assemble()
 
 

diff --git a/cwl_airflow/utilities/cwl.py b/cwl_airflow/utilities/cwl.py
@@ -845,9 +845,6 @@ def fast_cwl_step_load(workflow, target_id, cwl_args=None, location=None):
         workflow=workflow,
         cwl_args=default_cwl_args
     )
-    # modified
-    workflow_tool = embed_all_runs(workflow_tool, cwl_args=default_cwl_args)
-    # modified
     selected_step = list(get_items(workflow_tool["steps"], target_id))[0][1]
 
     workflow_steps.append(selected_step)