Skip to content

Commit

Permalink
Fix assignment of template field in __init__ in `analyticdb_spark.p…
Browse files Browse the repository at this point in the history
…y` (#36911)

* remove unecessary templated fields

* reverting templeting field and fix assignment in constructor
  • Loading branch information
romsharon98 authored Jan 19, 2024
1 parent 888300f commit 98fb11b
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions airflow/providers/alibaba/cloud/operators/analyticdb_spark.py
Original file line number Diff line number Diff line change
Expand Up @@ -131,15 +131,15 @@ def __init__(
) -> None:
super().__init__(**kwargs)

self.spark_params = {
spark_params = {
"sql": sql,
"conf": conf,
"driver_resource_spec": driver_resource_spec,
"executor_resource_spec": executor_resource_spec,
"num_executors": num_executors,
"name": name,
}

self.spark_params = spark_params
self._cluster_id = cluster_id
self._rg_name = rg_name

Expand Down Expand Up @@ -196,7 +196,7 @@ def __init__(
) -> None:
super().__init__(**kwargs)

self.spark_params = {
spark_params = {
"file": file,
"class_name": class_name,
"args": args,
Expand All @@ -210,7 +210,7 @@ def __init__(
"archives": archives,
"name": name,
}

self.spark_params = spark_params
self._cluster_id = cluster_id
self._rg_name = rg_name

Expand Down

0 comments on commit 98fb11b

Please sign in to comment.