File tree Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Original file line number Diff line number Diff line change @@ -1050,7 +1050,17 @@ def make_field_func(*pair):
1050
1050
expansions = defaultdict (list )
1051
1051
for node in graph_in .nodes ():
1052
1052
for src_id in list (old_edge_dict .keys ()):
1053
- if re .match (src_id + r'(\.[a-z]\d+)?$' , node .itername ):
1053
+ # Drop the original JoinNodes; only concerned with
1054
+ # generated Nodes
1055
+ if hasattr (node , 'joinfield' ):
1056
+ continue
1057
+ # Patterns:
1058
+ # - src_id : Non-iterable node
1059
+ # - src_id.[a-z]\d+ : IdentityInterface w/ iterables
1060
+ # - src_id.[a-z]I.[a-z]\d+ : Non-IdentityInterface w/ iterables
1061
+ # - src_idJ\d+ : JoinNode(IdentityInterface)
1062
+ if re .match (src_id + r'((\.[a-z](I\.[a-z])?|J)\d+)?$' ,
1063
+ node .itername ):
1054
1064
expansions [src_id ].append (node )
1055
1065
for in_id , in_nodes in list (expansions .items ()):
1056
1066
logger .debug ("The join node %s input %s was expanded"
You can’t perform that action at this time.
0 commit comments