Wrap sync fs for xarray.to_zarr

moradology · Dec 4, 2024 · 18bc6f7 · 18bc6f7
1 parent d005ff7
commit 18bc6f7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/zarr/storage/remote.py b/src/zarr/storage/remote.py
@@ -166,6 +166,9 @@ def from_url(
         opts = {"asynchronous": True, **opts}
 
         fs, path = url_to_fs(url, **opts)
+        if not fs.async_impl:
+            from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper
+            fs = AsyncFileSystemWrapper(fs)
 
         # fsspec is not consistent about removing the scheme from the path, so check and strip it here
         # https://github.com/fsspec/filesystem_spec/issues/1722