Skip to content

Commit abc5fdf

Browse files
committed
Add another test
1 parent 4b7a5eb commit abc5fdf

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

tests/test_store/test_fsspec.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
from zarr.core.buffer import Buffer, cpu, default_buffer_prototype
1515
from zarr.core.sync import _collect_aiterator, sync
1616
from zarr.storage import FsspecStore
17+
from zarr.storage._fsspec import _make_async
1718
from zarr.testing.store import StoreTests
1819

1920
if TYPE_CHECKING:
@@ -154,6 +155,15 @@ def test_open_s3map_raises() -> None:
154155
zarr.open(store=mapper, mode="w", shape=(3, 3), storage_options={"anon": True})
155156

156157

158+
@pytest.mark.parametrize("asynchronous", [True, False])
159+
def test_make_async(asynchronous: bool) -> None:
160+
s3_filesystem = s3fs.S3FileSystem(
161+
asynchronous=asynchronous, endpoint_url=endpoint_url, anon=False
162+
)
163+
fs = _make_async(s3_filesystem)
164+
assert fs.asynchronous
165+
166+
157167
class TestFsspecStoreS3(StoreTests[FsspecStore, cpu.Buffer]):
158168
store_cls = FsspecStore
159169
buffer_cls = cpu.Buffer

0 commit comments

Comments
 (0)