Skip to content

Commit

Permalink
n=0 special case
Browse files Browse the repository at this point in the history
  • Loading branch information
dwsutherland committed Nov 6, 2020
1 parent 73e59d6 commit 2e475b0
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions cylc/flow/data_store_mgr.py
Original file line number Diff line number Diff line change
Expand Up @@ -586,16 +586,18 @@ def increment_graph_window(
# This part is vital to constructing a set of boundary nodes
# associated with the current Active node.
if edge_distance > self.n_edge_distance:
if descendant or edge_distance == 0:
if descendant and self.n_edge_distance > 0:
self.n_window_boundary_nodes[
active_id].setdefault(edge_distance, set()).add(s_id)
return
graph_children = generate_graph_children(
self.schd.config.get_taskdef(name), point)
if not any(graph_children.values()):
if descendant or edge_distance == 0:
self.n_window_boundary_nodes[
active_id].setdefault(edge_distance, set()).add(s_id)
if (
(not any(graph_children.values()) and descendant)
or self.n_edge_distance == 0
):
self.n_window_boundary_nodes[
active_id].setdefault(edge_distance, set()).add(s_id)

self.n_window_nodes[active_id].add(s_id)
# Generate task node
Expand Down

0 comments on commit 2e475b0

Please sign in to comment.