This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 7e1f67b4b8 Fix a bug in method name used in `GlacierToGCSOperator`
(#35978)
7e1f67b4b8 is described below
commit 7e1f67b4b89e50b51d21f38b35a809583eea991e
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Thu Nov 30 17:32:20 2023 +0200
Fix a bug in method name used in `GlacierToGCSOperator` (#35978)
---
airflow/providers/amazon/aws/transfers/glacier_to_gcs.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/transfers/glacier_to_gcs.py
b/airflow/providers/amazon/aws/transfers/glacier_to_gcs.py
index 60ee579025..4bc65919b1 100644
--- a/airflow/providers/amazon/aws/transfers/glacier_to_gcs.py
+++ b/airflow/providers/amazon/aws/transfers/glacier_to_gcs.py
@@ -98,7 +98,7 @@ class GlacierToGCSOperator(BaseOperator):
# Read the file content in chunks using StreamingBody
#
https://botocore.amazonaws.com/v1/documentation/api/latest/reference/response.html
stream = glacier_data["body"]
- for chunk in stream.iter_chunk(chunk_size=self.chunk_size):
+ for chunk in stream.iter_chunks(chunk_size=self.chunk_size):
temp_file.write(chunk)
temp_file.flush()
gcs_hook.upload(
