Skip to content

Commit 4ef5a97

Browse files
committed
pass down args
1 parent 0d463b9 commit 4ef5a97

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

pyiceberg/io/pyarrow.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,9 +87,12 @@
8787
ADLS_ACCOUNT_NAME,
8888
ADLS_BLOB_STORAGE_AUTHORITY,
8989
ADLS_BLOB_STORAGE_SCHEME,
90+
ADLS_CLIENT_ID,
91+
ADLS_CLIENT_SECRET,
9092
ADLS_DFS_STORAGE_AUTHORITY,
9193
ADLS_DFS_STORAGE_SCHEME,
9294
ADLS_SAS_TOKEN,
95+
ADLS_TENANT_ID,
9396
AWS_ACCESS_KEY_ID,
9497
AWS_REGION,
9598
AWS_ROLE_ARN,
@@ -535,6 +538,13 @@ def _initialize_azure_fs(self) -> FileSystem:
535538
if sas_token := self.properties.get(ADLS_SAS_TOKEN):
536539
client_kwargs["sas_token"] = sas_token
537540

541+
if client_id := self.properties.get(ADLS_CLIENT_ID):
542+
client_kwargs["client_id"] = client_id
543+
if client_secret := self.properties.get(ADLS_CLIENT_SECRET):
544+
client_kwargs["client_secret"] = client_secret
545+
if tenant_id := self.properties.get(ADLS_TENANT_ID):
546+
client_kwargs["tenant_id"] = tenant_id
547+
538548
return AzureFileSystem(**client_kwargs)
539549

540550
def _initialize_hdfs_fs(self, scheme: str, netloc: Optional[str]) -> FileSystem:

0 commit comments

Comments
 (0)