Add missing import for AsyncFileSystemWrapper for _make_async in _fsspec.py (#3195)

tasansal · Altay Sansal · web-flow · commit 97aa42f551c2 · 2025-07-03T11:06:24.000+02:00
* Add missing import for AsyncFileSystemWrapper in `_fsspec.py`

* Add missing changelog entry for AsyncFileSystemWrapper import fix

* Move AsyncFileSystemWrapper import past the version check in `_fsspec.py`

* Add newline after AsyncFileSystemWrapper import in `_fsspec.py`

* Simplify import statement for AsyncFileSystemWrapper in `_fsspec.py`

---------

Co-authored-by: Altay Sansal &lt;altay.sansal@tgs.com&gt;
diff --git a/changes/3195.bugfix.rst b/changes/3195.bugfix.rst
@@ -0,0 +1 @@
+Add missing import for AsyncFileSystemWrapper for _make_async in _fsspec.py
diff --git a/src/zarr/storage/_fsspec.py b/src/zarr/storage/_fsspec.py
@@ -68,7 +68,9 @@ def _make_async(fs: AbstractFileSystem) -> AsyncFileSystem:
             "2024.12.0 or later to enable this functionality."
         )
 
-    return fsspec.implementations.asyn_wrapper.AsyncFileSystemWrapper(fs, asynchronous=True)
+    from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper
+
+    return AsyncFileSystemWrapper(fs, asynchronous=True)
 
 
 class FsspecStore(Store):

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+Add missing import for AsyncFileSystemWrapper for _make_async in _fsspec.py`
Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,9 @@ def _make_async(fs: AbstractFileSystem) -> AsyncFileSystem:`
`68`	`68`	`"2024.12.0 or later to enable this functionality."`
`69`	`69`	`)`
`70`	`70`
`71`		`- return fsspec.implementations.asyn_wrapper.AsyncFileSystemWrapper(fs, asynchronous=True)`
	`71`	`+ from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper`
	`72`	`+`
	`73`	`+ return AsyncFileSystemWrapper(fs, asynchronous=True)`
`72`	`74`
`73`	`75`
`74`	`76`	`class FsspecStore(Store):`