We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7bc9992 commit a1b28c8Copy full SHA for a1b28c8
pandas/io/parquet.py
@@ -300,9 +300,14 @@ def read(
300
if is_fsspec_url(path):
301
fsspec = import_optional_dependency("fsspec")
302
303
- parquet_kwargs["open_with"] = lambda path, _: fsspec.open(
304
- path, "rb", **(storage_options or {})
305
- ).open()
+ if Version(self.api.__version__) > Version("0.6.1"):
+ parquet_kwargs["fs"] = fsspec.open(
+ path, "rb", **(storage_options or {})
306
+ ).fs
307
+ else:
308
+ parquet_kwargs["open_with"] = lambda path, _: fsspec.open(
309
310
+ ).open()
311
elif isinstance(path, str) and not os.path.isdir(path):
312
# use get_handle only when we are very certain that it is not a directory
313
# fsspec resources can also point to directories
0 commit comments