[airflow] branch master updated: Fix bug in GCSToS3Operator (#13718)

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kaxilnaik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/master by this push:
     new ab5fe56  Fix bug in GCSToS3Operator (#13718)
ab5fe56 is described below

commit ab5fe56ac4bda0d3fcdcbf58ed2632255b7ac713
Author: phucbui95 <41...@users.noreply.github.com>
AuthorDate: Sun Jan 17 04:47:16 2021 +0700

    Fix bug in GCSToS3Operator (#13718)
---
 airflow/providers/amazon/aws/transfers/gcs_to_s3.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/amazon/aws/transfers/gcs_to_s3.py b/airflow/providers/amazon/aws/transfers/gcs_to_s3.py
index 4b552e4..b0035ff 100644
--- a/airflow/providers/amazon/aws/transfers/gcs_to_s3.py
+++ b/airflow/providers/amazon/aws/transfers/gcs_to_s3.py
@@ -175,7 +175,7 @@ class GCSToS3Operator(BaseOperator):
         if files:
 
             for file in files:
-                file_bytes = hook.download(self.bucket, file)
+                file_bytes = hook.download(object_name=file, bucket_name=self.bucket)
 
                 dest_key = self.dest_s3_key + file
                 self.log.info("Saving file to %s", dest_key)