From 5d2daaeb82515029880d52c412511dd446fe9490 Mon Sep 17 00:00:00 2001 From: Amisha Singla Date: Wed, 2 Oct 2024 14:06:45 -0500 Subject: [PATCH] Add task sla update fix task name --- airflow_variables_dev.json | 1 + dags/stellar_etl_airflow/build_dbt_task.py | 1 + 2 files changed, 2 insertions(+) diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index 367e3228..4776f5e1 100644 --- a/airflow_variables_dev.json +++ b/airflow_variables_dev.json @@ -331,6 +331,7 @@ "ttl": "ttl" }, "task_sla": { + "all_sources": 720, "asset_stats": 720, "build_batch_stats": 840, "build_bq_insert_job": 1080, diff --git a/dags/stellar_etl_airflow/build_dbt_task.py b/dags/stellar_etl_airflow/build_dbt_task.py index 195c7781..3b120a6b 100644 --- a/dags/stellar_etl_airflow/build_dbt_task.py +++ b/dags/stellar_etl_airflow/build_dbt_task.py @@ -117,6 +117,7 @@ def dbt_task( logging.info(f"sh commands to run in pod: {args}") + command_type = command_type.replace(" ", "_") return KubernetesPodOperator( task_id=f"dbt_{command_type}_{task_name}", name=f"dbt_{command_type}_{task_name}",