diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index 067bd307..ee1f49f2 100644 --- a/airflow_variables_dev.json +++ b/airflow_variables_dev.json @@ -123,7 +123,7 @@ "partnership_assets__account_holders_activity_fact": false, "partnership_assets__asset_activity_fact": false }, - "dbt_image_name": "stellar/stellar-dbt:e58c444a5", + "dbt_image_name": "stellar/stellar-dbt:333f8f1df", "dbt_internal_source_db": "test-hubble-319619", "dbt_internal_source_schema": "test_crypto_stellar_internal", "dbt_job_execution_timeout_seconds": 300, diff --git a/airflow_variables_prod.json b/airflow_variables_prod.json index 09128d93..2fef6a85 100644 --- a/airflow_variables_prod.json +++ b/airflow_variables_prod.json @@ -124,7 +124,7 @@ "partnership_assets__asset_activity_fact": false, "trade_agg": false }, - "dbt_image_name": "stellar/stellar-dbt:e58c444a5", + "dbt_image_name": "stellar/stellar-dbt:333f8f1df", "dbt_internal_source_db": "hubble-261722", "dbt_internal_source_schema": "crypto_stellar_internal_2", "dbt_job_execution_timeout_seconds": 1800, diff --git a/dags/stellar_etl_airflow/build_dbt_task.py b/dags/stellar_etl_airflow/build_dbt_task.py index bb8667a9..6da6858b 100644 --- a/dags/stellar_etl_airflow/build_dbt_task.py +++ b/dags/stellar_etl_airflow/build_dbt_task.py @@ -132,7 +132,7 @@ def dbt_task( "INTERNAL_SOURCE_SCHEMA": "{{ var.value.dbt_internal_source_schema }}", "PUBLIC_SOURCE_DB": "{{ var.value.dbt_public_source_db }}", "PUBLIC_SOURCE_SCHEMA": "{{ var.value.dbt_public_source_schema }}", - "EXECUTION_DATE": "{{ ds }}", + "EXECUTION_DATE": "{{ ts }}", }, image=dbt_image, arguments=args, @@ -173,7 +173,7 @@ def build_dbt_task( create_dbt_profile_cmd = create_dbt_profile(project) - execution_date = "EXECUTION_DATE=" + "{{ ds }}" + execution_date = "EXECUTION_DATE=" + "{{ ts }}" command = ["sh", "-c"] args = [