From 23bec28dba4b718a5a55708f67fcaf017a1d8b0c Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Fri, 21 Mar 2025 16:50:05 +0100 Subject: [PATCH 1/2] Update pyiron_base.py --- .../src/python_workflow_definition/pyiron_base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python_workflow_definition/src/python_workflow_definition/pyiron_base.py b/python_workflow_definition/src/python_workflow_definition/pyiron_base.py index de2fe46..9afff86 100644 --- a/python_workflow_definition/src/python_workflow_definition/pyiron_base.py +++ b/python_workflow_definition/src/python_workflow_definition/pyiron_base.py @@ -72,7 +72,7 @@ def get_dict(**kwargs): def get_list(**kwargs): - return list(kwargs["kwargs"].values()) + return {f"s_{i}": v for i, v in enumerate(kwargs["kwargs"].values())} def _remove_server_obj(nodes_dict, edges_lst): @@ -156,7 +156,7 @@ def _get_edges_dict(edges_lst, nodes_dict, connection_dict, lookup_dict): "target": target, "targetHandle": target_handle, "source": connection_dict[output_name], - "sourceHandle": output._list_index, # check for list index + "sourceHandle": f"s_{output._list_index}", # check for list index }) else: edges_dict_lst.append({ From e302816abaaacd5b9a6e03022d639549eb76d19c Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Fri, 21 Mar 2025 17:01:37 +0100 Subject: [PATCH 2/2] Update pyiron_base.py --- .../src/python_workflow_definition/pyiron_base.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/python_workflow_definition/src/python_workflow_definition/pyiron_base.py b/python_workflow_definition/src/python_workflow_definition/pyiron_base.py index 9afff86..2a4c303 100644 --- a/python_workflow_definition/src/python_workflow_definition/pyiron_base.py +++ b/python_workflow_definition/src/python_workflow_definition/pyiron_base.py @@ -58,8 +58,6 @@ def _get_delayed_object_dict(total_lst, nodes_dict, source_handle_dict, pyiron_p ) for k, v in input_dict.items() } - # print(nodes_dict[key], source_handle_dict.get(key, [])) - # print(kwargs) delayed_object_dict[key] = job( funct=nodes_dict[key], output_key_lst=source_handle_dict.get(key, []), @@ -72,7 +70,7 @@ def get_dict(**kwargs): def get_list(**kwargs): - return {f"s_{i}": v for i, v in enumerate(kwargs["kwargs"].values())} + return list(kwargs["kwargs"].values()) def _remove_server_obj(nodes_dict, edges_lst):