Fix test

crusaderky · crusaderky · commit 81563136fff0 · 2022-04-24T21:37:54.000+01:00
diff --git a/distributed/tests/test_worker_memory.py b/distributed/tests/test_worker_memory.py
@@ -636,6 +636,7 @@ def leak():
     assert "memory" in out.lower()
 
 
+@pytest.mark.slow
 @gen_cluster(
     nthreads=[("", 1)],
     client=True,
@@ -674,9 +675,11 @@ def __reduce__(self):
     while a.status != Status.paused:
         await asyncio.sleep(0.01)
         # The initial spill still hasn't finished
-        assert len(a.data.slow) < 7
+        assert a.data.fast
+    assert a.data.fast
 
 
+@pytest.mark.slow
 @gen_cluster(
     nthreads=[("", 1)],
     client=True,
