This is an automated email from the ASF dual-hosted git repository. eladkal 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 98fb11b650 Fix assignment of template field in `__init__` in `analyticdb_spark.py` (#36911) 98fb11b650 is described below commit 98fb11b6502efad034492b16acd73a059e82baff Author: rom sharon <33751805+romsharo...@users.noreply.github.com> AuthorDate: Fri Jan 19 22:24:30 2024 +0200 Fix assignment of template field in `__init__` in `analyticdb_spark.py` (#36911) * remove unecessary templated fields * reverting templeting field and fix assignment in constructor --- airflow/providers/alibaba/cloud/operators/analyticdb_spark.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py b/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py index 106f7583cb..1ea8f8a970 100644 --- a/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py +++ b/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py @@ -131,7 +131,7 @@ class AnalyticDBSparkSQLOperator(AnalyticDBSparkBaseOperator): ) -> None: super().__init__(**kwargs) - self.spark_params = { + spark_params = { "sql": sql, "conf": conf, "driver_resource_spec": driver_resource_spec, @@ -139,7 +139,7 @@ class AnalyticDBSparkSQLOperator(AnalyticDBSparkBaseOperator): "num_executors": num_executors, "name": name, } - + self.spark_params = spark_params self._cluster_id = cluster_id self._rg_name = rg_name @@ -196,7 +196,7 @@ class AnalyticDBSparkBatchOperator(AnalyticDBSparkBaseOperator): ) -> None: super().__init__(**kwargs) - self.spark_params = { + spark_params = { "file": file, "class_name": class_name, "args": args, @@ -210,7 +210,7 @@ class AnalyticDBSparkBatchOperator(AnalyticDBSparkBaseOperator): "archives": archives, "name": name, } - + self.spark_params = spark_params self._cluster_id = cluster_id self._rg_name = rg_name