From c9f0d49e74ec87e330e2e1292e3d6c3125bcec14 Mon Sep 17 00:00:00 2001 From: fjetter Date: Mon, 26 Aug 2024 16:20:33 +0200 Subject: [PATCH] bump timeout for pause_while_saturated --- distributed/tests/test_worker_memory.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/distributed/tests/test_worker_memory.py b/distributed/tests/test_worker_memory.py index 94742a8f94..4a222861d8 100644 --- a/distributed/tests/test_worker_memory.py +++ b/distributed/tests/test_worker_memory.py @@ -1112,17 +1112,17 @@ async def test_pause_while_saturated(c, s, a, b): sa = s.workers[a.address] ev = Event() futs = c.map(lambda i, ev: ev.wait(), range(3), ev=ev, workers=[a.address]) - await async_poll_for(lambda: len(a.state.tasks) == 3, timeout=2) + await async_poll_for(lambda: len(a.state.tasks) == 3, timeout=5) assert sa in s.saturated assert sa in s.running a.monitor.get_process_memory = lambda: 2**40 - await async_poll_for(lambda: sa.status == Status.paused, timeout=2) + await async_poll_for(lambda: sa.status == Status.paused, timeout=5) assert sa not in s.saturated assert sa not in s.running a.monitor.get_process_memory = lambda: 0 - await async_poll_for(lambda: sa.status == Status.running, timeout=2) + await async_poll_for(lambda: sa.status == Status.running, timeout=5) assert sa in s.saturated assert sa in s.running