minor fix

2024-05-02 14:54:17 +02:00 · 2024-05-02 14:54:17 +02:00 · 372da136df
parent 7eb5e35753
commit 372da136df
1 changed files with 1 additions and 1 deletions
--- a/airflow/dags/run_spark.py
+++ b/airflow/dags/run_spark.py
@ -80,7 +80,7 @@ dag = DAG(
 )

 submit = SparkKubernetesOperator(
-    task_id='spark-scholix-{{ ds }}-{{ task_instance.try_number }}',
+    task_id='spark-scholix',
    namespace='dnet-spark-jobs',
    template_spec=spec,
    kubernetes_conn_id="kubernetes_default",