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 8e6bfc2956 fix assignment of templated field in constructor (#36603)
8e6bfc2956 is described below
commit 8e6bfc2956254127479e751f94a4adcb3d7552c4
Author: rom sharon <[email protected]>
AuthorDate: Sat Jan 13 18:57:35 2024 +0200
fix assignment of templated field in constructor (#36603)
---
airflow/providers/google/cloud/transfers/sftp_to_gcs.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/google/cloud/transfers/sftp_to_gcs.py
b/airflow/providers/google/cloud/transfers/sftp_to_gcs.py
index eee8bd14b5..d22cc8ae3e 100644
--- a/airflow/providers/google/cloud/transfers/sftp_to_gcs.py
+++ b/airflow/providers/google/cloud/transfers/sftp_to_gcs.py
@@ -97,8 +97,8 @@ class SFTPToGCSOperator(BaseOperator):
super().__init__(**kwargs)
self.source_path = source_path
- self.destination_path = self._set_destination_path(destination_path)
- self.destination_bucket = self._set_bucket_name(destination_bucket)
+ self.destination_path = destination_path
+ self.destination_bucket = destination_bucket
self.gcp_conn_id = gcp_conn_id
self.mime_type = mime_type
self.gzip = gzip
@@ -108,6 +108,8 @@ class SFTPToGCSOperator(BaseOperator):
self.sftp_prefetch = sftp_prefetch
def execute(self, context: Context):
+ self.destination_path =
self._set_destination_path(self.destination_path)
+ self.destination_bucket =
self._set_bucket_name(self.destination_bucket)
gcs_hook = GCSHook(
gcp_conn_id=self.gcp_conn_id,
impersonation_chain=self.impersonation_chain,
