File tree Expand file tree Collapse file tree 1 file changed +0
-5
lines changed
src/python_workflow_definition Expand file tree Collapse file tree 1 file changed +0
-5
lines changed Original file line number Diff line number Diff line change 1111from python_workflow_definition .shared import (
1212 convert_nodes_list_to_dict ,
1313 update_node_names ,
14- remove_result ,
1514 set_result_node ,
1615 NODES_LABEL ,
1716 EDGES_LABEL ,
2726def load_workflow_json (file_name : str ) -> WorkGraph :
2827
2928 data = PythonWorkflowDefinitionWorkflow .load_json_file (file_name = file_name )
30- # data = remove_result(workflow_dict=workflow_dict)
3129
3230 wg = WorkGraph ()
3331 task_name_mapping = {}
@@ -68,9 +66,6 @@ def load_workflow_json(file_name: str) -> WorkGraph:
6866 try :
6967 if link [SOURCE_PORT_LABEL ] is None :
7068 link [SOURCE_PORT_LABEL ] = "result"
71- # if link[SOURCE_PORT_LABEL] == 'result':
72- # pass
73- # link[SOURCE_PORT_LABEL] = "__result__"
7469 # because we are not define the outputs explicitly during the pythonjob creation
7570 # we add it here, and assume the output exit
7671 if link [SOURCE_PORT_LABEL ] not in from_task .outputs :
You can’t perform that action at this time.
0 commit comments