Skip to content

Commit 575bc96

Browse files
committed
Clean up pure python
1 parent 1adbba9 commit 575bc96

File tree

1 file changed

+1
-14
lines changed
  • python_workflow_definition/src/python_workflow_definition

1 file changed

+1
-14
lines changed

python_workflow_definition/src/python_workflow_definition/purepython.py

Lines changed: 1 addition & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from inspect import isfunction
44

55

6-
from python_workflow_definition.shared import get_dict, get_list, get_kwargs
6+
from python_workflow_definition.shared import get_dict, get_list, get_kwargs, get_source_handles
77

88

99
def resort_total_lst(total_lst, nodes_dict):
@@ -35,19 +35,6 @@ def group_edges(edges_lst):
3535
return total_lst
3636

3737

38-
def get_source_handles(edges_lst):
39-
source_handle_dict = {}
40-
for ed in edges_lst:
41-
if ed['source'] not in source_handle_dict.keys():
42-
source_handle_dict[ed['source']] = [ed['sourceHandle']]
43-
else:
44-
source_handle_dict[ed['source']].append(ed['sourceHandle'])
45-
return {
46-
k: list(range(len(v))) if len(v) > 1 and all([el is None for el in v]) else v
47-
for k, v in source_handle_dict.items()
48-
}
49-
50-
5138
def get_value(result_dict, nodes_new_dict, link_dict):
5239
source, source_handle = link_dict["source"], link_dict["sourceHandle"]
5340
if source in result_dict.keys():

0 commit comments

Comments
 (0)