Skip to content

Commit

Permalink
Replace default empty dict value by None in AzureBlobStorageToS3Opera…
Browse files Browse the repository at this point in the history
…tor (#35977)
  • Loading branch information
hussein-awala authored Nov 30, 2023
1 parent ddb4370 commit 4a9824d
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py
Original file line number Diff line number Diff line change
Expand Up @@ -90,8 +90,8 @@ def __init__(
dest_s3_extra_args: dict | None = None,
replace: bool = False,
s3_acl_policy: str | None = None,
wasb_extra_args: dict = {},
s3_extra_args: dict = {},
wasb_extra_args: dict | None = None,
s3_extra_args: dict | None = None,
**kwargs,
) -> None:
super().__init__(**kwargs)
Expand All @@ -106,8 +106,8 @@ def __init__(
self.dest_s3_extra_args = dest_s3_extra_args or {}
self.replace = replace
self.s3_acl_policy = s3_acl_policy
self.wasb_extra_args = wasb_extra_args
self.s3_extra_args = s3_extra_args
self.wasb_extra_args = wasb_extra_args or {}
self.s3_extra_args = s3_extra_args or {}

def execute(self, context: Context) -> list[str]:
# list all files in the Azure Blob Storage container
Expand Down

0 comments on commit 4a9824d

Please sign in to comment.