This is an automated email from the ASF dual-hosted git repository.
husseinawala pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 4a9824de8e Replace default empty dict value by None in
AzureBlobStorageToS3Operator (#35977)
4a9824de8e is described below
commit 4a9824de8e063ee78a18583de24cd59718adc7f7
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Thu Nov 30 18:04:51 2023 +0200
Replace default empty dict value by None in AzureBlobStorageToS3Operator
(#35977)
---
airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py
b/airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py
index fe207b5957..034460b861 100644
--- a/airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py
+++ b/airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py
@@ -90,8 +90,8 @@ class AzureBlobStorageToS3Operator(BaseOperator):
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)
@@ -106,8 +106,8 @@ class AzureBlobStorageToS3Operator(BaseOperator):
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
