Fix assignment of template field in __init__ in hive_to_samba.py (#…

…36486)
apache · Dec 29, 2023 · 0722679 · 0722679
1 parent ed9080a
commit 0722679
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/providers/apache/hive/transfers/hive_to_samba.py b/airflow/providers/apache/hive/transfers/hive_to_samba.py
@@ -61,9 +61,10 @@ def __init__(
         self.hiveserver2_conn_id = hiveserver2_conn_id
         self.samba_conn_id = samba_conn_id
         self.destination_filepath = destination_filepath
-        self.hql = hql.strip().rstrip(";")
+        self.hql = hql
 
     def execute(self, context: Context):
+        self.hql = self.hql.strip().rstrip(";")
         with NamedTemporaryFile() as tmp_file:
             self.log.info("Fetching file from Hive")
             hive = HiveServer2Hook(hiveserver2_conn_id=self.hiveserver2_conn_id)