Spaces:
Runtime error
Runtime error
File size: 573 Bytes
63deadc |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
import pytest
import fsspec
pytest.importorskip("distributed")
@pytest.fixture()
def cli(tmpdir):
import dask.distributed
client = dask.distributed.Client(n_workers=1)
def setup():
m = fsspec.filesystem("memory")
with m.open("afile", "wb") as f:
f.write(b"data")
client.run(setup)
try:
yield client
finally:
client.shutdown()
def test_basic(cli):
fs = fsspec.filesystem("dask", target_protocol="memory")
assert fs.ls("", detail=False) == ["/afile"]
assert fs.cat("/afile") == b"data"
|