Skip to content

Commit 1344f9c

Browse files
committed
Fix comment
1 parent 3579451 commit 1344f9c

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

distributed/scheduler.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8485,7 +8485,13 @@ def coassignmnet_groups(
84858485
while len(next.dependents) == 1:
84868486
dep = list(next.dependents)[0]
84878487
if len(dep.dependencies) != 1:
8488-
# This algorithm has the shortcoming that groups may grow too large if the dependent of a group
8488+
# This algorithm has the shortcoming that groups may grow
8489+
# too large if we walk straight to the dependent of a group.
8490+
# Especially in staged reductions (e.g. tree reductions, the
8491+
# next "jump" would combine multiple cogroups). For now,
8492+
# just ignore these. This means that we'll practically only
8493+
# have cogroups at the bottom of a graph but this is where
8494+
# it matters the most anyhow
84898495
group_dependents_seen.add(dep)
84908496
break
84918497
next = dep

0 commit comments

Comments
 (0)