diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index 9f0f25ec06..c75d8abd7e 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -3807,8 +3807,8 @@ def test_unique_task_heap(): assert repr(heap) == "" -@gen_cluster(client=True, nthreads=[]) -async def test_do_not_block_event_loop_during_shutdown(c, s): +@gen_cluster(nthreads=[]) +async def test_do_not_block_event_loop_during_shutdown(s): loop = asyncio.get_running_loop() called_handler = threading.Event() block_handler = threading.Event()