Skip to content

Commit ce1d0f1

Browse files
authored
Remove zict-related skips (#5429)
1 parent afce4be commit ce1d0f1

File tree

3 files changed

+2
-9
lines changed

3 files changed

+2
-9
lines changed

distributed/spill.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,11 @@
44
from functools import partial
55
from typing import Any
66

7+
from zict import Buffer, File, Func
8+
79
from .protocol import deserialize_bytes, serialize_bytelist
810
from .sizeof import safe_sizeof
911

10-
try:
11-
from zict import Buffer, File, Func
12-
except ImportError:
13-
raise ImportError("Please `python -m pip install zict` for spill-to-disk workers")
14-
1512

1613
class SpillBuffer(Buffer):
1714
"""MutableMapping that automatically spills out dask key/value pairs to disk when

distributed/tests/test_scheduler.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2473,8 +2473,6 @@ async def assert_memory(scheduler_or_workerstate, attr: str, min_, max_, timeout
24732473
client=True, Worker=Nanny, worker_kwargs={"memory_limit": "500 MiB"}, timeout=120
24742474
)
24752475
async def test_memory(c, s, *_):
2476-
pytest.importorskip("zict")
2477-
24782476
# WorkerState objects, as opposed to the Nanny objects passed by gen_cluster
24792477
a, b = s.workers.values()
24802478

distributed/tests/test_spill.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
import pytest
22

3-
pytest.importorskip("zict")
4-
53
from dask.sizeof import sizeof
64

75
from distributed.spill import SpillBuffer

0 commit comments

Comments
 (0)