From 6d91816417765c092e4a66d4637bdfec965e2c04 Mon Sep 17 00:00:00 2001 From: Gabe Joseph Date: Thu, 17 Jun 2021 12:20:58 -0600 Subject: [PATCH] no-sleep test --- distributed/tests/test_scheduler.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/distributed/tests/test_scheduler.py b/distributed/tests/test_scheduler.py index 4229106e9fe..20fc41a6eb9 100644 --- a/distributed/tests/test_scheduler.py +++ b/distributed/tests/test_scheduler.py @@ -135,13 +135,11 @@ async def test_decide_worker_select_candidate_holding_no_deps(client, s, a, b, c root = await client.scatter(1) assert sum(root.key in worker.data for worker in [a, b, c]) == 1 - start = time() - tasks = client.map(sleep, [root] * 6, pure=False) + tasks = client.map(inc, [root] * 6, pure=False) await wait(tasks) - elapsed = time() - start - assert elapsed <= 4 assert all(root.key in worker.data for worker in [a, b, c]) + assert len(a.data) == len(b.data) == len(c.data) == 3 @gen_cluster(client=True, nthreads=[("127.0.0.1", 1)] * 3)