From 51fe1e417f9b83107e017e8e5d2ca42554a2c8b0 Mon Sep 17 00:00:00 2001 From: dip Date: Fri, 14 Feb 2025 17:02:49 +0100 Subject: [PATCH] support wasb and wasbs --- pyiceberg/io/__init__.py | 2 ++ pyiceberg/io/fsspec.py | 2 ++ 2 files changed, 4 insertions(+) diff --git a/pyiceberg/io/__init__.py b/pyiceberg/io/__init__.py index ac25c2d767..9d0f083b04 100644 --- a/pyiceberg/io/__init__.py +++ b/pyiceberg/io/__init__.py @@ -304,6 +304,8 @@ def delete(self, location: Union[str, InputFile, OutputFile]) -> None: "viewfs": [ARROW_FILE_IO], "abfs": [FSSPEC_FILE_IO], "abfss": [FSSPEC_FILE_IO], + "wasb": [FSSPEC_FILE_IO], + "wasbs": [FSSPEC_FILE_IO], } diff --git a/pyiceberg/io/fsspec.py b/pyiceberg/io/fsspec.py index d8fe3dfa40..3417168fb6 100644 --- a/pyiceberg/io/fsspec.py +++ b/pyiceberg/io/fsspec.py @@ -217,6 +217,8 @@ def _adls(properties: Properties) -> AbstractFileSystem: "s3n": _s3, "abfs": _adls, "abfss": _adls, + "wasb": _adls, + "wasbs": _adls, "gs": _gs, "gcs": _gs, }