Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
Kimahriman committed Nov 7, 2024
1 parent cb99fa9 commit d4bb0d3
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
8 changes: 7 additions & 1 deletion python/hdfs_native/fsspec.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,13 @@
class HdfsFileSystem(AbstractFileSystem):
root_marker = "/"

def __init__(self, host: Optional[str] = None, port: Optional[int] = None, *args, **storage_options):
def __init__(
self,
host: Optional[str] = None,
port: Optional[int] = None,
*args,
**storage_options,
):
super().__init__(host, port, *args, **storage_options)
self.host = host
self.port = port
Expand Down
3 changes: 2 additions & 1 deletion python/tests/test_fsspec.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,10 @@

def test_config(minidfs: str):
url = urllib.parse.urlparse(minidfs)
fs: HdfsFileSystem = fsspec.filesystem(url.scheme, **{'fs.defaultFS': minidfs})
fs: HdfsFileSystem = fsspec.filesystem(url.scheme, **{"fs.defaultFS": minidfs})
assert len(fs.ls("/")) == 0


def test_dirs(fs: HdfsFileSystem):
fs.mkdir("/testdir")
assert fs.info("/testdir")["type"] == "directory"
Expand Down

0 comments on commit d4bb0d3

Please sign in to comment.