File tree Expand file tree Collapse file tree 1 file changed +5
-8
lines changed Expand file tree Collapse file tree 1 file changed +5
-8
lines changed Original file line number Diff line number Diff line change @@ -1054,21 +1054,18 @@ def make_field_func(*pair):
1054
1054
for src_id in list (old_edge_dict .keys ()):
1055
1055
# Drop the original JoinNodes; only concerned with
1056
1056
# generated Nodes
1057
- if hasattr (node , 'joinfield' ):
1058
- logger .warning ("Dropping JoinNode: %s; src_id: %s" ,
1059
- node .itername , src_id )
1057
+ if hasattr (node , 'joinfield' ) and node .itername == src_id :
1060
1058
continue
1061
1059
# Patterns:
1062
1060
# - src_id : Non-iterable node
1063
- # - src_id.[a-z]\d+ : IdentityInterface w/ iterables
1064
- # - src_id.[a-z]I.[a-z]\d+ : Non-IdentityInterface w/ iterables
1061
+ # - src_id.[a-z]\d+ :
1062
+ # IdentityInterface w/ iterables or nested JoinNode
1063
+ # - src_id.[a-z]I.[a-z]\d+ :
1064
+ # Non-IdentityInterface w/ iterables
1065
1065
# - src_idJ\d+ : JoinNode(IdentityInterface)
1066
1066
if re .match (src_id + r'((\.[a-z](I\.[a-z])?|J)\d+)?$' ,
1067
1067
node .itername ):
1068
1068
expansions [src_id ].append (node )
1069
- else :
1070
- logger .debug ("Unmatched pattern: %s; src_id: %s" ,
1071
- node .itername , src_id )
1072
1069
for in_id , in_nodes in list (expansions .items ()):
1073
1070
logger .debug ("The join node %s input %s was expanded"
1074
1071
" to %d nodes." , jnode , in_id , len (in_nodes ))
You can’t perform that action at this time.
0 commit comments