From 90401375bf62502db5f671773f18a2654978a5a9 Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Fri, 9 Dec 2022 14:37:54 +0100 Subject: [PATCH] Unskip test --- distributed/shuffle/tests/test_shuffle.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/distributed/shuffle/tests/test_shuffle.py b/distributed/shuffle/tests/test_shuffle.py index b3f8385da9..c5bfad6a3a 100644 --- a/distributed/shuffle/tests/test_shuffle.py +++ b/distributed/shuffle/tests/test_shuffle.py @@ -993,10 +993,8 @@ async def test_restrictions(c, s, a, b): assert all(stringify(key) in a.data for key in y.__dask_keys__()) -@pytest.mark.skip(reason="Don't clean up forgotten shuffles") @gen_cluster(client=True) async def test_delete_some_results(c, s, a, b): - # FIXME: This works but not reliably. It fails every ~25% of runs df = dask.datasets.timeseries( start="2000-01-01", end="2000-01-10", @@ -1010,10 +1008,10 @@ async def test_delete_some_results(c, s, a, b): x = x.partitions[: x.npartitions // 2].persist() await c.compute(x.size) - - # await clean_worker(a) - # await clean_worker(b) - # await clean_scheduler(s) + del x + await clean_worker(a) + await clean_worker(b) + await clean_scheduler(s) @gen_cluster(client=True)