We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1c480a5 commit e788280Copy full SHA for e788280
1 file changed
pyiceberg/io/fsspec.py
@@ -299,7 +299,8 @@ def new_input(self, location: str) -> FsspecInputFile:
299
FsspecInputFile: An FsspecInputFile instance for the given location.
300
"""
301
uri = urlparse(location)
302
- fs = self.get_fs(uri.scheme)
+ scheme = uri.scheme or "file"
303
+ fs = self.get_fs(scheme)
304
return FsspecInputFile(location=location, fs=fs)
305
306
def new_output(self, location: str) -> FsspecOutputFile:
0 commit comments