File tree Expand file tree Collapse file tree 1 file changed +16
-8
lines changed
python_workflow_definition/src/python_workflow_definition/cwl Expand file tree Collapse file tree 1 file changed +16
-8
lines changed Original file line number Diff line number Diff line change @@ -204,14 +204,22 @@ def _write_workflow(workflow):
204204 if v [SOURCE_LABEL ] in input_id_dict :
205205 in_dict [k + "_file" ] = input_id_dict [v [SOURCE_LABEL ]] + "_file"
206206 else :
207- in_dict [k + "_file" ] = (
208- step_name_lst [v [SOURCE_LABEL ]]
209- + "_"
210- + str (v [SOURCE_LABEL ])
211- + "/"
212- + v [SOURCE_PORT_LABEL ]
213- + "_file"
214- )
207+ if v ['sourcePort' ] is None :
208+ in_dict [k + "_file" ] = (
209+ step_name_lst [v [SOURCE_LABEL ]]
210+ + "_"
211+ + str (v [SOURCE_LABEL ])
212+ + "/result_file"
213+ )
214+ else :
215+ in_dict [k + "_file" ] = (
216+ step_name_lst [v [SOURCE_LABEL ]]
217+ + "_"
218+ + str (v [SOURCE_LABEL ])
219+ + "/"
220+ + v [SOURCE_PORT_LABEL ]
221+ + "_file"
222+ )
215223 workflow_template ["steps" ].update (
216224 {
217225 step_name_lst [ind ]
You can’t perform that action at this time.
0 commit comments