Instantiate async filesystem inside the desired loop

scikit-hep · Oct 16, 2023 · 202783a · 202783a
1 parent 7bc543c
commit 202783a
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/uproot/source/fsspec.py b/src/uproot/source/fsspec.py
@@ -41,9 +41,11 @@ def __init__(self, file_path, **options):
             if self._fs.async_impl:
                 self._executor = uproot.source.futures.LoopExecutor()
                 # Bind the loop to the filesystem
-                self._fs = fsspec.filesystem(
-                    protocol=self._fs.protocol, loop=self._executor.loop
-                )
+                async def make_fs():
+                    return fsspec.filesystem(
+                        protocol=self._fs.protocol, loop=self._executor.loop
+                    )
+                self._fs = self._executor.submit(make_fs).result()
             else:
                 self._executor = concurrent.futures.ThreadPoolExecutor(
                     max_workers=self._num_workers