From d9ebab2661845c9a3c4672e1770d25a299f59a48 Mon Sep 17 00:00:00 2001 From: Matthew Rocklin Date: Wed, 23 Mar 2022 10:12:21 -0500 Subject: [PATCH] fixup test --- distributed/tests/test_worker.py | 19 ++++--------------- 1 file changed, 4 insertions(+), 15 deletions(-) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index 1d30e11625..b168592a14 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -3320,19 +3320,8 @@ async def test_tick_interval(c, s, a, b): await a.heartbeat() x = s.workers[a.address].metrics["event_loop_interval"] - assert x - assert 0.0001 < x < 1 - old = a._tick_interval_observed - - old_count_last = a._tick_count_last - - time.sleep(0.500) # Block event loop - - while a._tick_count_last == old_count_last: + while s.workers[a.address].metrics["event_loop_interval"] > 0.050: await asyncio.sleep(0.01) - - await a.heartbeat() - y = s.workers[a.address].metrics["event_loop_interval"] - new = a._tick_interval_observed - - assert y > x + while s.workers[a.address].metrics["event_loop_interval"] < 0.100: + await asyncio.sleep(0.01) + time.sleep(0.200)