diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index a8b71fce..c0133a73 100644 --- a/airflow_variables_dev.json +++ b/airflow_variables_dev.json @@ -122,7 +122,7 @@ "partnership_assets__account_holders_activity_fact": false, "partnership_assets__asset_activity_fact": false }, - "dbt_image_name": "stellar/stellar-dbt:bbe7478", + "dbt_image_name": "stellar/stellar-dbt:d35ca76", "dbt_job_execution_timeout_seconds": 300, "dbt_job_retries": 1, "dbt_mart_dataset": "test_sdf_marts", @@ -338,7 +338,7 @@ }, "currency_bucket": "currencies_ohlc", "max_db_entry_age_in_days": 90, - "public_dbt_image_name": "stellar/stellar-dbt:bbe7478", + "public_dbt_image_name": "stellar/stellar-dbt:d35ca76", "internal_source_db": "test-hubble-319619", "internal_source_schema": "test_crypto_stellar_internal", "public_source_db": "test-hubble-319619", diff --git a/airflow_variables_prod.json b/airflow_variables_prod.json index 1cb3bbf9..a4050136 100644 --- a/airflow_variables_prod.json +++ b/airflow_variables_prod.json @@ -144,7 +144,7 @@ "partnership_assets__asset_activity_fact": false, "trade_agg": false }, - "dbt_image_name": "stellar/stellar-dbt:bbe7478", + "dbt_image_name": "stellar/stellar-dbt:d35ca76", "dbt_job_execution_timeout_seconds": 1800, "dbt_job_retries": 1, "dbt_mart_dataset": "sdf_marts", @@ -358,7 +358,7 @@ }, "currency_bucket": "ext-asset-pricing", "max_db_entry_age_in_days": 180, - "public_dbt_image_name": "stellar/stellar-dbt:bbe7478", + "public_dbt_image_name": "stellar/stellar-dbt:d35ca76", "internal_source_db": "hubble-261722", "internal_source_schema": "crypto_stellar_internal_2", "public_source_db": "crypto-stellar", diff --git a/dags/dbt_sdf_marts_dag.py b/dags/dbt_sdf_marts_dag.py index 0c042aeb..ff65cdb7 100644 --- a/dags/dbt_sdf_marts_dag.py +++ b/dags/dbt_sdf_marts_dag.py @@ -41,6 +41,7 @@ network_stats_agg_task = dbt_task(dag, tag="network_stats") partnership_assets_task = dbt_task(dag, tag="partnership_assets") history_assets = dbt_task(dag, tag="history_assets") +soroban = dbt_task(dag, tag="soroban") # DAG task graph wait_on_dbt_enriched_base_tables >> ohlc_task >> liquidity_pool_trade_volume_task @@ -55,3 +56,4 @@ wait_on_dbt_enriched_base_tables >> network_stats_agg_task wait_on_dbt_enriched_base_tables >> partnership_assets_task wait_on_dbt_enriched_base_tables >> history_assets +wait_on_dbt_enriched_base_tables >> soroban