fix

Eventual-Inc · Dec 20, 2024 · 368b1c2 · 368b1c2
1 parent 5e9207c
commit 368b1c2
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/daft/filesystem.py b/daft/filesystem.py
@@ -294,10 +294,8 @@ def _set_if_not_none(kwargs: dict[str, Any], key: str, val: Any | None):
         return resolved_path, resolved_filesystem
 
     elif protocol == "hdfs":
-        print(f"path is {path}, unwrap_protocol is {_unwrap_protocol(path)}")
         resolved_filesystem = pafs.HadoopFileSystem.from_uri(path)
-        resolved_path = resolved_filesystem.normalize_path(_unwrap_protocol(resolved_path))
-        print(f"resolved_filesystem is {resolved_filesystem}, and resolved_path is {resolved_path}")
+        resolved_path = resolved_filesystem.normalize_path(path)
         return resolved_path, resolved_filesystem
 
     else: