File tree Expand file tree Collapse file tree 1 file changed +9
-1
lines changed
python_workflow_definition/src/python_workflow_definition/cwl Expand file tree Collapse file tree 1 file changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -170,6 +170,8 @@ def _write_workflow(workflow):
170170 "result_file" : {
171171 "type" : "File" ,
172172 "outputSource" : function_nodes_dict [last_compute_id ].split ("." )[- 1 ]
173+ + "_"
174+ + str (last_compute_id )
173175 + "/result_file" ,
174176 },
175177 }
@@ -204,12 +206,18 @@ def _write_workflow(workflow):
204206 else :
205207 in_dict [k + "_file" ] = (
206208 step_name_lst [v [SOURCE_LABEL ]]
209+ + "_"
210+ + str (v [SOURCE_LABEL ])
207211 + "/"
208212 + v [SOURCE_PORT_LABEL ]
209213 + "_file"
210214 )
211215 workflow_template ["steps" ].update (
212- {step_name_lst [ind ] + "_" + str (ind ): {"run" : node_script , "in" : in_dict , "out" : output }}
216+ {
217+ step_name_lst [ind ]
218+ + "_"
219+ + str (ind ): {"run" : node_script , "in" : in_dict , "out" : output }
220+ }
213221 )
214222 with open ("workflow.cwl" , "w" ) as f :
215223 dump (workflow_template , f , Dumper = Dumper )
You can’t perform that action at this time.
0 commit comments