diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index 1e68a81a890..7421fed1756 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -3363,9 +3363,7 @@ async def gather_dep(self, *args, **kwargs): @pytest.mark.parametrize("intermediate_state", ["resumed", "cancelled"]) -@pytest.mark.parametrize( - "close_worker", [False, pytest.param(True, marks=pytest.mark.slow)] -) +@pytest.mark.parametrize("close_worker", [False, True]) @gen_cluster(client=True) async def test_deadlock_cancelled_after_inflight_before_gather_from_worker( c, s, a, x, intermediate_state, close_worker