| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -84,7 +84,7 @@ def _allocate_filter_stream_names(filter_nodes, outgoing_edge_maps, stream_name_ | |||
| 84 | 84 | stream_count = 0 | |
| 85 | 85 | for upstream_node in filter_nodes: | |
| 86 | 86 | outgoing_edge_map = outgoing_edge_maps[upstream_node] | |
| 87 | - for upstream_label, downstreams in list(outgoing_edge_map.items()): | ||
| 87 | + for upstream_label, downstreams in sorted(outgoing_edge_map.items()): | ||
| 88 | 88 | if len(downstreams) > 1: | |
| 89 | 89 | # TODO: automatically insert `splits` ahead of time via graph transformation. | |
| 90 | 90 | raise ValueError( | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -100,7 +100,7 @@ def get_incoming_edges(downstream_node, incoming_edge_map): | |||
| 100 | 100 | ||
| 101 | 101 | def get_outgoing_edges(upstream_node, outgoing_edge_map): | |
| 102 | 102 | edges = [] | |
| 103 | - for upstream_label, downstream_infos in list(outgoing_edge_map.items()): | ||
| 103 | + for upstream_label, downstream_infos in sorted(outgoing_edge_map.items()): | ||
| 104 | 104 | for downstream_info in downstream_infos: | |
| 105 | 105 | downstream_node, downstream_label, downstream_selector = downstream_info | |
| 106 | 106 | edges += [ | |
| Back | FazBrowse Home | New Git URL |
0 commit comments