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 <[email protected]>
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
