diff --git a/pyiceberg/io/__init__.py b/pyiceberg/io/__init__.py index 172dd44b93..d5920a028b 100644 --- a/pyiceberg/io/__init__.py +++ b/pyiceberg/io/__init__.py @@ -88,6 +88,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 8c8f6936ce..b15821ace7 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, @@ -240,6 +241,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), )