Fix dbt execution date

stellar · Apr 26, 2023 · 752c311 · 752c311
1 parent cfee699
commit 752c311
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS
@@ -1,2 +1,2 @@
 # Require Horizon team reviews
-* @stellar/platform-committers
+* @stellar/platform-data-committers
diff --git a/dags/stellar_etl_airflow/build_dbt_task.py b/dags/stellar_etl_airflow/build_dbt_task.py
@@ -80,11 +80,13 @@ def build_dbt_task(dag, model_name, resource_cfg="default"):
         dbt_full_refresh = "--full-refresh"
 
     create_dbt_profile_cmd = create_dbt_profile()
+
+    execution_date = "EXECUTION_DATE=" + "{{ ds }}"
 
     command = ["sh", "-c"]
     args = [
         " ".join(
-            [create_dbt_profile_cmd, "dbt run --select", model_name, dbt_full_refresh]
+            [create_dbt_profile_cmd, execution_date, "dbt run --select", model_name, dbt_full_refresh]
         )
     ]
     logging.info(f"sh commands to run in pod: {args}")