We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f360fc6 commit 38a841cCopy full SHA for 38a841c
src/zarr/storage/fsspec.py
@@ -3,6 +3,8 @@
3
import warnings
4
from typing import TYPE_CHECKING, Any
5
6
+from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper
7
+
8
from zarr.abc.store import ByteRangeRequest, Store
9
from zarr.storage.common import _dereference_path
10
@@ -166,6 +168,8 @@ def from_url(
166
168
opts = {"asynchronous": True, **opts}
167
169
170
fs, path = url_to_fs(url, **opts)
171
+ if not fs.async_impl:
172
+ fs = AsyncFileSystemWrapper(fs)
173
174
# fsspec is not consistent about removing the scheme from the path, so check and strip it here
175
# https://github.com/fsspec/filesystem_spec/issues/1722
0 commit comments