From 5d6570d987370719859c8fd43764e4526f0afaf3 Mon Sep 17 00:00:00 2001 From: James Bourbeau Date: Thu, 30 Sep 2021 20:18:37 -0500 Subject: [PATCH 1/2] Mark test_worker_reconnects_mid_compute_multiple_states_on_scheduler as flaky --- distributed/tests/test_worker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index 8d9ebc2fac9..ec3461aa7f0 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -2523,6 +2523,7 @@ def fast_on_a(lock): await asyncio.sleep(0.001) +@pytest.mark.flaky(reruns=10, reruns_delay=5) @gen_cluster(client=True) async def test_worker_reconnects_mid_compute_multiple_states_on_scheduler(c, s, a, b): """ From 59b2bf022604fd71981c924cfd7d975e41dc9206 Mon Sep 17 00:00:00 2001 From: James Bourbeau Date: Tue, 5 Oct 2021 11:23:27 -0500 Subject: [PATCH 2/2] Mark test_worker_reconnects_mid_compute as flaky too --- distributed/tests/test_worker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index ec3461aa7f0..f3cad58a9f7 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -2455,6 +2455,7 @@ async def test_hold_on_to_replicas(c, s, *workers): await asyncio.sleep(0.01) +@pytest.mark.flaky(reruns=10, reruns_delay=5) @gen_cluster(client=True) async def test_worker_reconnects_mid_compute(c, s, a, b): """Ensure that, if a worker disconnects while computing a result, the scheduler will