From 1c0a178134c06aca977d0dadd2572e2f3cf029e4 Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Fri, 13 Sep 2024 14:54:57 +0200 Subject: [PATCH] Remove outdated test --- distributed/shuffle/tests/test_shuffle.py | 27 ----------------------- 1 file changed, 27 deletions(-) diff --git a/distributed/shuffle/tests/test_shuffle.py b/distributed/shuffle/tests/test_shuffle.py index 0efff85f68..23e61eef2d 100644 --- a/distributed/shuffle/tests/test_shuffle.py +++ b/distributed/shuffle/tests/test_shuffle.py @@ -2685,33 +2685,6 @@ async def barrier(self, id: ShuffleId, run_id: int, consistent: bool) -> None: return await super().barrier(id, run_id, consistent) -@gen_cluster(client=True) -async def test_unpack_is_non_rootish(c, s, a, b): - with pytest.warns(UserWarning): - scheduler_plugin = BlockedBarrierShuffleSchedulerPlugin(s) - df = dask.datasets.timeseries( - start="2000-01-01", - end="2000-01-21", - dtypes={"x": float, "y": float}, - freq="10 s", - ) - df = df.shuffle("x") - result = c.compute(df) - - await scheduler_plugin.in_barrier.wait() - - unpack_tss = [ts for key, ts in s.tasks.items() if key_split(key) == UNPACK_PREFIX] - assert len(unpack_tss) == 20 - assert not any(s.is_rootish(ts) for ts in unpack_tss) - del unpack_tss - scheduler_plugin.block_barrier.set() - result = await result - - await assert_worker_cleanup(a) - await assert_worker_cleanup(b) - await assert_scheduler_cleanup(s) - - class FlakyConnectionPool(ConnectionPool): def __init__(self, *args, failing_connects=0, **kwargs): self.attempts = 0