Change import structure to protect against AttributeError

maxrjones · maxrjones · commit 1772c894e36b · 2025-07-02T10:37:02.000-04:00
diff --git a/src/zarr/storage/_fsspec.py b/src/zarr/storage/_fsspec.py
@@ -62,8 +62,9 @@ def _make_async(fs: AbstractFileSystem) -> AsyncFileSystem:
             "AsyncFileSystemWrapper is not available. Upgrade fsspec to version "
             "2024.12.0 or later to enable this functionality."
         )
+    from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper
 
-    return fsspec.implementations.asyn_wrapper.AsyncFileSystemWrapper(fs, asynchronous=True)
+    return AsyncFileSystemWrapper(fs, asynchronous=True)
 
 
 class FsspecStore(Store):

Original file line number	Diff line number	Diff line change
`@@ -62,8 +62,9 @@ def _make_async(fs: AbstractFileSystem) -> AsyncFileSystem:`
`62`	`62`	`"AsyncFileSystemWrapper is not available. Upgrade fsspec to version "`
`63`	`63`	`"2024.12.0 or later to enable this functionality."`
`64`	`64`	`)`
	`65`	`+ from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper`
`65`	`66`
`66`		`- return fsspec.implementations.asyn_wrapper.AsyncFileSystemWrapper(fs, asynchronous=True)`
	`67`	`+ return AsyncFileSystemWrapper(fs, asynchronous=True)`
`67`	`68`
`68`	`69`
`69`	`70`	`class FsspecStore(Store):`