oops

dask · Nov 25, 2022 · 9026d47 · 9026d47
1 parent 926198a
commit 9026d47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/tests/test_scheduler.py b/distributed/tests/test_scheduler.py
@@ -4200,7 +4200,7 @@ def assert_rootish():
         block_on_event, range(nblocking_tasks), block=block2, executing=executing2
     )
 
-    while len(s.tasks) == nblocking_tasks + len(keys):
+    while len(s.tasks) != nblocking_tasks + len(keys):
         await asyncio.sleep(0.005)
 
     # Once the task is on the threadpool, the client/scheduler may start its