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):
10541054 for src_id in list (old_edge_dict .keys ()):
10551055 # Drop the original JoinNodes; only concerned with
10561056 # 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 :
10601058 continue
10611059 # Patterns:
10621060 # - 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
10651065 # - src_idJ\d+ : JoinNode(IdentityInterface)
10661066 if re .match (src_id + r'((\.[a-z](I\.[a-z])?|J)\d+)?$' ,
10671067 node .itername ):
10681068 expansions [src_id ].append (node )
1069- else :
1070- logger .debug ("Unmatched pattern: %s; src_id: %s" ,
1071- node .itername , src_id )
10721069 for in_id , in_nodes in list (expansions .items ()):
10731070 logger .debug ("The join node %s input %s was expanded"
10741071 " to %d nodes." , jnode , in_id , len (in_nodes ))
You can’t perform that action at this time.
0 commit comments