Add task sla

update fix task name
stellar · Oct 2, 2024 · 5d2daae · 5d2daae
1 parent 63ed062
commit 5d2daae
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -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}",