diff --git a/distributed/scheduler.py b/distributed/scheduler.py
index 75c6fe259be..2ba9f124161 100644
--- a/distributed/scheduler.py
+++ b/distributed/scheduler.py
@@ -2485,6 +2485,7 @@ def decide_worker(self, ts: TaskState) -> WorkerState:
         if (
             valid_workers is None
             and len(group) > self._total_nthreads * 2
+            and len(group._dependencies) < 5
             and sum(map(len, group._dependencies)) < 5
         ):
             ws: WorkerState = group._last_worker