shorten sleep time in distributed test

mrocklin · Aug 10, 2015 · caf537f · caf537f
1 parent d6683a2
commit caf537f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dask/distributed/tests/test_scheduler.py b/dask/distributed/tests/test_scheduler.py
@@ -281,7 +281,7 @@ def test_collect_retry():
         result = w1.pool.apply_async(w1.collect,
                                      args=({'x': [w2.address, w3.address]},))
         while not w1.queues_by_worker:
-            sleep(0.1)
+            sleep(0.01)
         while w2.address in s.workers:
             s.prune_and_notify(timeout=0.1)