Ersetze fsspec.core.strip_protocol durch split_protocol und füge lokalen strip_protocol‑Wrapper in dataset, io, metadata, schema und helpers/security hinzu. Bump-Version auf 0.22.3

Author: legout

pydala/dataset.py

@@ -15,7 +15,7 @@
 import pyarrow.dataset as pds
 import tqdm
 from fsspec import AbstractFileSystem
-from fsspec.core import strip_protocol
+from fsspec.core import split_protocol
 
 # Initialize logger
 logger = logging.getLogger(__name__)
@@ -41,6 +41,18 @@
 from .table import PydalaTable
 
 
+def strip_protocol(path: str) -> str:
+    """Strips the protocol from a given path.
+
+    Args:
+        path (str): The input path which may contain a protocol.
+    Returns:
+        str: The path without the protocol.
+    """
+    protocol, path = split_protocol(path)
+    return path
+
+
 class BaseDataset:
     """A base class for dataset operations supporting multiple file formats.
 

pydala/helpers/security.py

@@ -5,7 +5,19 @@
 import re
 import string
 from typing import Any
-from fsspec.core import strip_protocol
+from fsspec.core import split_protocol
+
+
+def strip_protocol(path: str) -> str:
+    """Strips the protocol from a given path.
+
+    Args:
+        path (str): The input path which may contain a protocol.
+    Returns:
+        str: The path without the protocol.
+    """
+    protocol, path = split_protocol(path)
+    return path
 
 
 def escape_sql_identifier(identifier: str) -> str:

pydala/io.py

@@ -13,7 +13,7 @@
 import pyarrow.parquet as pq
 from fsspec import AbstractFileSystem
 from fsspec import filesystem as fsspec_filesystem
-from fsspec.core import strip_protocol
+from fsspec.core import split_protocol
 from loguru import logger
 
 # Local imports
@@ -24,6 +24,18 @@
 from .table import PydalaTable
 
 
+def strip_protocol(path: str) -> str:
+    """Strips the protocol from a given path.
+
+    Args:
+        path (str): The input path which may contain a protocol.
+    Returns:
+        str: The path without the protocol.
+    """
+    protocol, path = split_protocol(path)
+    return path
+
+
 def write_table(
     table: pa.Table,
     path: str,

pydala/metadata.py

@@ -14,7 +14,7 @@
 import pyarrow.fs as pfs
 import pyarrow.parquet as pq
 from fsspec import AbstractFileSystem
-from fsspec.core import strip_protocol
+from fsspec.core import split_protocol
 from loguru import logger
 
 from .filesystem import FileSystem, clear_cache
@@ -28,6 +28,18 @@
 )
 
 
+def strip_protocol(path: str) -> str:
+    """Strips the protocol from a given path.
+
+    Args:
+        path (str): The input path which may contain a protocol.
+    Returns:
+        str: The path without the protocol.
+    """
+    protocol, path = split_protocol(path)
+    return path
+
+
 def serialize_metadata(metadata: dict[str, pq.FileMetaData]) -> dict[str, Any]:
     """Safely serialize metadata to a JSON-compatible format.
 

pydala/schema.py

@@ -5,10 +5,22 @@
 import pyarrow.fs as pfs
 import pyarrow.parquet as pq
 from fsspec import AbstractFileSystem
-from fsspec.core import strip_protocol
+from fsspec.core import split_protocol
 from .helpers.misc import read_table, run_parallel, unify_schemas_pl
 
 
+def strip_protocol(path: str) -> str:
+    """Strips the protocol from a given path.
+
+    Args:
+        path (str): The input path which may contain a protocol.
+    Returns:
+        str: The path without the protocol.
+    """
+    protocol, path = split_protocol(path)
+    return path
+
+
 def sort_schema(schema: pa.Schema, names: list[str] | None = None) -> pa.Schema:
     """Sort fields of a pyarrow schema in alphabetical order.
 

pyproject.toml

@@ -25,7 +25,7 @@ name = "pydala2"
 readme = "README.md"
 #repository = "https://github.com/legout/pydala2"
 requires-python = ">= 3.11"
-version = "0.22.2"
+version = "0.22.3"
 
 [project.optional-dependencies]
 legacy = ["polars-lts-cpu>=0.20.4"]