File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -711,7 +711,7 @@ def generate_expanded_graph(graph_in):
711
711
in_edges = jedge_dict [jnode ] = {}
712
712
edges2remove = []
713
713
for src , dest , data in graph_in .in_edges_iter (jnode , True ):
714
- in_edges [src ._id ] = data
714
+ in_edges [src .fullname ] = data
715
715
edges2remove .append ((src , dest ))
716
716
717
717
for src , dest in edges2remove :
@@ -796,7 +796,7 @@ def make_field_func(*pair):
796
796
expansions = defaultdict (list )
797
797
for node in graph_in .nodes_iter ():
798
798
for src_id , edge_data in list (old_edge_dict .items ()):
799
- if node ._id .startswith (src_id ):
799
+ if node .fullname .startswith (src_id ):
800
800
expansions [src_id ].append (node )
801
801
for in_id , in_nodes in list (expansions .items ()):
802
802
logger .debug ("The join node %s input %s was expanded"
You can’t perform that action at this time.
0 commit comments