From af7d9cbc9a3f8d571632abd9584e37e49828cf18 Mon Sep 17 00:00:00 2001 From: Matthew Rocklin Date: Thu, 24 Mar 2022 14:49:40 -0500 Subject: [PATCH] Maybe fix test_worker_waits_for_scheduler Previously this was timing out in some test runs. One *possible* issue is that we started a coroutine to ask the scheduler to release us, but the scheduler doesn't exist. This removes that request. I'm not confident that this will fix the issue. I give around a 30% chance. However, I am fairly confident that this won't have negative consequences. --- distributed/tests/test_worker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index 0caa128c02b..0d6bd78f19e 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -311,7 +311,7 @@ async def test_worker_port_range(s): @pytest.mark.slow -@gen_test(timeout=60) +@gen_test() async def test_worker_waits_for_scheduler(): w = Worker("127.0.0.1:8724") try: @@ -321,7 +321,7 @@ async def test_worker_waits_for_scheduler(): else: assert False assert w.status not in (Status.closed, Status.running, Status.paused) - await w.close(timeout=0.1) + await w.close(report=False) @gen_cluster(client=True, nthreads=[("127.0.0.1", 1)])