diff --git a/pyiceberg/io/__init__.py b/pyiceberg/io/__init__.py index c7109993c9..96e35037c2 100644 --- a/pyiceberg/io/__init__.py +++ b/pyiceberg/io/__init__.py @@ -83,6 +83,7 @@ ADLS_BLOB_STORAGE_SCHEME = "adls.blob-storage-scheme" ADLS_DFS_STORAGE_SCHEME = "adls.dfs-storage-scheme" ADLS_TOKEN = "adls.token" +ADLS_ANON = "adls.anon" GCS_TOKEN = "gcs.oauth2.token" GCS_TOKEN_EXPIRES_AT_MS = "gcs.oauth2.token-expires-at" GCS_PROJECT_ID = "gcs.project-id" diff --git a/pyiceberg/io/fsspec.py b/pyiceberg/io/fsspec.py index 5898a22675..e152dc505f 100644 --- a/pyiceberg/io/fsspec.py +++ b/pyiceberg/io/fsspec.py @@ -42,6 +42,7 @@ ADLS_ACCOUNT_HOST, ADLS_ACCOUNT_KEY, ADLS_ACCOUNT_NAME, + ADLS_ANON, ADLS_CLIENT_ID, ADLS_CLIENT_SECRET, ADLS_CONNECTION_STRING, @@ -266,6 +267,7 @@ async def get_token(self, *scopes: str, **kwargs: Any) -> AccessToken: client_id=properties.get(ADLS_CLIENT_ID), client_secret=properties.get(ADLS_CLIENT_SECRET), account_host=properties.get(ADLS_ACCOUNT_HOST), + anon=properties.get(ADLS_ANON), ) diff --git a/tests/io/test_fsspec.py b/tests/io/test_fsspec.py index c28eb0714f..4ed26f23e2 100644 --- a/tests/io/test_fsspec.py +++ b/tests/io/test_fsspec.py @@ -601,6 +601,7 @@ def test_adls_account_name_sas_token_extraction() -> None: client_id=None, client_secret=None, account_host="testaccount.dfs.core.windows.net", + anon=None, )