fix: replace usage of image main for dbt-deps (et/somenergia-jardiner…

…!159) Merge branch 'fix/bad-images-in-dags' into 'main'
Som-Energia · Sep 12, 2024 · 761061a · 761061a
2 parents 7aed68a + 71f329a
commit 761061a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/dags/plant_production_datasets_dag.py b/dags/plant_production_datasets_dag.py
@@ -77,14 +77,17 @@ def dbapi_to_dict(dbapi: str):
         "DBHOST": dbapi_dict["host"],
         "DBPORT": dbapi_dict["port"],
         "DBNAME": dbapi_dict["database"],
+        "DBT_PACKAGES_INSTALL_PATH": "/home/somenergia/.dbt/dbt_packages",
+        "DBT_PROFILES_DIR": "/repos/somenergia-jardiner/dbt_jardiner/config",
+        "DBT_PROJECT_DIR": "/repos/somenergia-jardiner/dbt_jardiner",
     }
 
     dbt_transformation_task = DockerOperator(
         api_version="auto",
         task_id="dbt_transformation_task",
         environment=environment,
         docker_conn_id="somenergia_harbor_dades_registry",
-        image="{}/{}-main:latest".format(
+        image="{}/{}-dbt-deps:latest".format(
             "{{ conn.somenergia_harbor_dades_registry.host }}",
             repo_name,
         ),

diff --git a/dags/plant_production_datasets_jardiner_dag.py b/dags/plant_production_datasets_jardiner_dag.py
@@ -79,14 +79,16 @@ def dbapi_to_dict(dbapi: str):
         "DBPORT": dbapi_dict["port"],
         "DBNAME": dbapi_dict["database"],
         "DBT_PACKAGES_INSTALL_PATH": "/home/somenergia/.dbt/dbt_packages",
+        "DBT_PROFILES_DIR": "/repos/somenergia-jardiner/dbt_jardiner/config",
+        "DBT_PROJECT_DIR": "/repos/somenergia-jardiner/dbt_jardiner",
     }
 
     dbt_transformation_task = DockerOperator(
         api_version="auto",
         task_id="dbt_transformation_task__jardiner",
         environment=environment,
         docker_conn_id="somenergia_harbor_dades_registry",
-        image="{}/{}-main:latest".format(
+        image="{}/{}-dbt-deps:latest".format(
             "{{ conn.somenergia_harbor_dades_registry.host }}",
             repo_name,
         ),