Update executorlib.py

jan-janssen · web-flow · commit 083e15735639 · 2025-05-17T06:09:24.000+02:00
diff --git a/python_workflow_definition/src/python_workflow_definition/executorlib.py b/python_workflow_definition/src/python_workflow_definition/executorlib.py
@@ -34,7 +34,7 @@ def _get_value(result_dict: dict, nodes_new_dict: dict, link_dict: dict, exe: Ex
     if source_handle is None:
         return result
     else:
-        return exe.submit(fn=get_item, obj=result, key=source_handle)
+        return exe.submit(get_item, obj=result, key=source_handle)
 
 
 def load_workflow_json(file_name: str, exe: Executor):
@@ -72,7 +72,7 @@ def load_workflow_json(file_name: str, exe: Executor):
                 )
                 for k, v in lst[1].items()
             }
-            result_dict[lst[0]] = exe.submit(fn=node, **kwargs)
+            result_dict[lst[0]] = exe.submit(node, **kwargs)
             last_key = lst[0]
 
     return result_dict[last_key]

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ def _get_value(result_dict: dict, nodes_new_dict: dict, link_dict: dict, exe: Ex`
`34`	`34`	`if source_handle is None:`
`35`	`35`	`return result`
`36`	`36`	`else:`
`37`		`- return exe.submit(fn=get_item, obj=result, key=source_handle)`
	`37`	`+ return exe.submit(get_item, obj=result, key=source_handle)`
`38`	`38`
`39`	`39`
`40`	`40`	`def load_workflow_json(file_name: str, exe: Executor):`
`@@ -72,7 +72,7 @@ def load_workflow_json(file_name: str, exe: Executor):`
`72`	`72`	`)`
`73`	`73`	`for k, v in lst[1].items()`
`74`	`74`	`}`
`75`		`- result_dict[lst[0]] = exe.submit(fn=node, **kwargs)`
	`75`	`+ result_dict[lst[0]] = exe.submit(node, **kwargs)`
`76`	`76`	`last_key = lst[0]`
`77`	`77`
`78`	`78`	`return result_dict[last_key]`