From 372da136df13751f5d53337ad7cb9c81bce4851f Mon Sep 17 00:00:00 2001 From: Sandro La Bruzzo Date: Thu, 2 May 2024 14:54:17 +0200 Subject: [PATCH] minor fix --- airflow/dags/run_spark.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/dags/run_spark.py b/airflow/dags/run_spark.py index b81e02a..5b31b3b 100644 --- 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",