fix

dask · May 6, 2022 · 0a53139 · 0a53139
1 parent 1f51728
commit 0a53139
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/distributed/tests/test_worker_memory.py b/distributed/tests/test_worker_memory.py
@@ -717,12 +717,12 @@ def leak():
         await future
     assert s.tasks["leak"].suspicious == 1
     assert await c.run(lambda dask_worker: "leak" in dask_worker.tasks) == {a.worker_address: False}
-    del future
+    future.release()
     while "leak" in s.tasks:
         await asyncio.sleep(0.01)
 
 
-#@pytest.mark.slow
+@pytest.mark.slow
 @gen_cluster(
     nthreads=[("", 1)],
     client=True,