Ben Cornelis
10/20/2025, 8:13 PMAzureConfig.storage_account or the AZURE_STORAGE_ACCOUNT environment variable.` but I also see code attempting to parse it from the uri: https://github.com/Eventual-Inc/Daft/blob/main/src/daft-io/src/azure_blob.rs#L116. I'm not sure why that's not working. I'm using an abfs uri of the form <abfs://container@account_name.dfs.core.windows.net/path/>Kevin Wang
10/22/2025, 12:55 AMBen Cornelis
10/22/2025, 2:56 PMKevin Wang
10/22/2025, 5:14 PMBen Cornelis
10/22/2025, 5:45 PMimport daft
from daft import col
daft.context.set_runner_ray()
df = daft.read_parquet(
"<abfs://my_container@my_account_name.dfs.core.windows.net/path/to/in_dir/>"
)
df = df.groupby("group_col").agg(col("count_col").count()).count()
df.write_parquet(
"<abfs://my_container@my_account_name.dfs.core.windows.net/path/to/out_dir/>"
)
(edited with the full context)Kevin Wang
10/22/2025, 6:14 PMAzureConfig.storage_accountBen Cornelis
10/22/2025, 9:32 PM