@@ -241,9 +241,7 @@ def load_workflow_json(file_name: str) -> Workflow:
241241 )
242242 counter_dict = {k : - 1 for k in total_counter_dict .keys ()}
243243 wf = Workflow (file_name .split ("." )[0 ])
244- nodes_look_up_dict = {
245- node ["id" ]: node ["value" ] for node in content [NODES_LABEL ]
246- }
244+ nodes_look_up_dict = {node ["id" ]: node ["value" ] for node in content [NODES_LABEL ]}
247245 for node_dict in content [NODES_LABEL ]:
248246 if node_dict ["type" ] == "function" :
249247 if node_dict ["value" ] == "python_workflow_definition.shared.get_dict" :
@@ -298,10 +296,15 @@ def load_workflow_json(file_name: str) -> Workflow:
298296 injected_attribute_access = nodes [source_id ].__getitem__ (source_port )
299297 upstream = injected_attribute_access
300298 downstream = nodes [target_id ]
301- if nodes_look_up_dict [target_id ] == "python_workflow_definition.shared.get_list" :
299+ if (
300+ nodes_look_up_dict [target_id ]
301+ == "python_workflow_definition.shared.get_list"
302+ ):
302303 setattr (downstream .inputs , "s_" + target_port , upstream )
303304 else :
304- setattr (downstream .inputs , target_port , upstream ) # Exploit input panel magic
305+ setattr (
306+ downstream .inputs , target_port , upstream
307+ ) # Exploit input panel magic
305308 # Warning: edge setup routine is bespoke for an environment where all nodes return
306309 # a single value or a dictionary
307310
0 commit comments