feat(dbt): add dbt pool

MTES-MCT · Sep 6, 2024 · f9f5856 · f9f5856
1 parent 6c839f7
commit f9f5856
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/dags/ingest_app_dependencies.py b/airflow/dags/ingest_app_dependencies.py
@@ -6,6 +6,7 @@
 from airflow.decorators import dag, task
 from gdaltools import ogr2ogr
 from include.container import Container
+from include.pools import DBT_POOL
 from pendulum import datetime
 
 
@@ -72,7 +73,7 @@ def ingest_app_scot_departements():
     def ingest_app_scot_regions():
         return ingest_table("public_data_scot_regions", "app_scot_regions")
 
-    @task.bash(retries=0, trigger_rule="all_success")
+    @task.bash(retries=0, trigger_rule="all_success", pool=DBT_POOL)
     def dbt_run(**context):
         return 'cd "${AIRFLOW_HOME}/include/sql/sparte" && dbt run -s app'