@@ -82,12 +82,10 @@ def get_edges(graph_dict, node_mapping_dict, nodes_links_dict):
8282def create_input_nodes (nodes_dict , edges_lst ):
8383 node_conversion_dict = {
8484 ed [SOURCE_LABEL ]: ed [TARGET_PORT_LABEL ]
85- for ed in edges_lst if ed [SOURCE_PORT_LABEL ] is None
86- }
87- nodes_to_create_dict = {
88- v : nodes_dict [k ]
89- for k , v in node_conversion_dict .items ()
85+ for ed in edges_lst
86+ if ed [SOURCE_PORT_LABEL ] is None
9087 }
88+ nodes_to_create_dict = {v : nodes_dict [k ] for k , v in node_conversion_dict .items ()}
9189 return nodes_to_create_dict , node_conversion_dict
9290
9391
@@ -99,7 +97,7 @@ def set_input_nodes(workflow, nodes_to_create_dict):
9997
10098def get_source_handles (edges_lst ):
10199 source_handle_dict = {}
102- for ed in edges_lst :
100+ for ed in edges_lst :
103101 if ed [SOURCE_LABEL ] not in source_handle_dict .keys ():
104102 source_handle_dict [ed [SOURCE_LABEL ]] = [ed [SOURCE_PORT_LABEL ]]
105103 else :
@@ -116,7 +114,13 @@ def get_function_nodes(nodes_dict, source_handle_dict):
116114
117115
118116def get_kwargs (lst ):
119- return {t [TARGET_PORT_LABEL ]: {SOURCE_LABEL : t [SOURCE_LABEL ], SOURCE_PORT_LABEL : t [SOURCE_PORT_LABEL ]} for t in lst }
117+ return {
118+ t [TARGET_PORT_LABEL ]: {
119+ SOURCE_LABEL : t [SOURCE_LABEL ],
120+ SOURCE_PORT_LABEL : t [SOURCE_PORT_LABEL ],
121+ }
122+ for t in lst
123+ }
120124
121125
122126def group_edges (edges_lst ):
@@ -141,11 +145,17 @@ def build_workflow(workflow, function_dict, total_dict, node_conversion_dict):
141145 kwargs_dict = {}
142146 for kw , vw in kwargs_link_dict .items ():
143147 if vw [SOURCE_LABEL ] in node_conversion_dict .keys ():
144- kwargs_dict [kw ] = workflow .__getattribute__ (node_conversion_dict [vw [SOURCE_LABEL ]])
145- else :
146- kwargs_dict [kw ] = workflow .__getattr__ ("tmp_" + str (vw [SOURCE_LABEL ])).__getitem__ (vw [SOURCE_PORT_LABEL ])
148+ kwargs_dict [kw ] = workflow .__getattribute__ (
149+ node_conversion_dict [vw [SOURCE_LABEL ]]
150+ )
151+ else :
152+ kwargs_dict [kw ] = workflow .__getattr__ (
153+ "tmp_" + str (vw [SOURCE_LABEL ])
154+ ).__getitem__ (vw [SOURCE_PORT_LABEL ])
147155 v .update (kwargs_dict )
148- workflow .__setattr__ ("tmp_" + str (k ), function_node (** v , validate_output_labels = False ))
156+ workflow .__setattr__ (
157+ "tmp_" + str (k ), function_node (** v , validate_output_labels = False )
158+ )
149159 return workflow , "tmp_" + str (k )
150160
151161
@@ -276,7 +286,7 @@ def load_workflow_json(file_name: str, workflow: Optional[Workflow] = None):
276286 nodes_new_dict = {}
277287 for k , v in convert_nodes_list_to_dict (nodes_list = content [NODES_LABEL ]).items ():
278288 if isinstance (v , str ) and "." in v :
279- p , m = v .rsplit ('.' , 1 )
289+ p , m = v .rsplit ("." , 1 )
280290 mod = import_module (p )
281291 nodes_new_dict [int (k )] = getattr (mod , m )
282292 else :
@@ -285,16 +295,20 @@ def load_workflow_json(file_name: str, workflow: Optional[Workflow] = None):
285295 if workflow is None :
286296 workflow = Workflow (file_name .split ("." )[0 ])
287297
288- nodes_to_create_dict , node_conversion_dict = create_input_nodes (nodes_dict = nodes_new_dict , edges_lst = edges_lst )
298+ nodes_to_create_dict , node_conversion_dict = create_input_nodes (
299+ nodes_dict = nodes_new_dict , edges_lst = edges_lst
300+ )
289301 wf = set_input_nodes (workflow = workflow , nodes_to_create_dict = nodes_to_create_dict )
290302
291303 source_handle_dict = get_source_handles (edges_lst = edges_lst )
292- function_dict = get_function_nodes (nodes_dict = nodes_new_dict , source_handle_dict = source_handle_dict )
304+ function_dict = get_function_nodes (
305+ nodes_dict = nodes_new_dict , source_handle_dict = source_handle_dict
306+ )
293307 total_dict = group_edges (edges_lst = edges_lst )
294308
295309 return build_workflow (
296310 workflow = wf ,
297311 function_dict = function_dict ,
298312 total_dict = total_dict ,
299313 node_conversion_dict = node_conversion_dict ,
300- )
314+ )
0 commit comments