Skip to content

Commit 2371f80

Browse files
skoschikkukushking
andauthored
fix(delta-rs): normalize AWS_SESSION_TOKEN=None to empty string for delta-rs compatibility (#3223)
Co-authored-by: Anton Kukushkin <[email protected]>
1 parent 9b84384 commit 2371f80

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

awswrangler/s3/_read_deltalake.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ def _set_default_storage_options_kwargs(
2525
) -> dict[str, Any]:
2626
defaults = {key.upper(): value for key, value in _utils.boto3_to_primitives(boto3_session=boto3_session).items()}
2727
defaults["AWS_REGION"] = defaults.pop("REGION_NAME")
28+
defaults["AWS_SESSION_TOKEN"] = "" if defaults["AWS_SESSION_TOKEN"] is None else defaults["AWS_SESSION_TOKEN"]
2829
s3_additional_kwargs = s3_additional_kwargs or {}
2930
return {
3031
**defaults,

awswrangler/s3/_write_deltalake.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ def _set_default_storage_options_kwargs(
2929
) -> dict[str, Any]:
3030
defaults = {key.upper(): value for key, value in _utils.boto3_to_primitives(boto3_session=boto3_session).items()}
3131
defaults["AWS_REGION"] = defaults.pop("REGION_NAME")
32-
32+
defaults["AWS_SESSION_TOKEN"] = "" if defaults["AWS_SESSION_TOKEN"] is None else defaults["AWS_SESSION_TOKEN"]
3333
s3_additional_kwargs = s3_additional_kwargs or {}
3434

3535
s3_lock_arguments = {}

0 commit comments

Comments
 (0)