From d79b944eb5b4b445cff8389d9338eeb7ee9a265a Mon Sep 17 00:00:00 2001 From: Simon Chow Date: Tue, 20 Feb 2024 16:17:39 -0500 Subject: [PATCH 1/2] Update dbt image --- airflow_variables_dev.json | 4 ++-- airflow_variables_prod.json | 4 ++-- dags/dbt_sdf_marts_dag.py | 2 ++ 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index c0133a73..fc8fde92 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:d35ca76", + "dbt_image_name": "stellar/stellar-dbt:7a218a2", "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:d35ca76", + "public_dbt_image_name": "stellar/stellar-dbt:7a218a2", "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 a4050136..9a42b9a0 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:d35ca76", + "dbt_image_name": "stellar/stellar-dbt:7a218a2", "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:d35ca76", + "public_dbt_image_name": "stellar/stellar-dbt:7a218a2", "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 ff65cdb7..a448605d 100644 --- a/dags/dbt_sdf_marts_dag.py +++ b/dags/dbt_sdf_marts_dag.py @@ -6,6 +6,8 @@ from stellar_etl_airflow.build_dbt_task import dbt_task from stellar_etl_airflow.default import get_default_dag_args +init_sentry() + dag = DAG( "dbt_sdf_marts", default_args=get_default_dag_args(), From 83c6d5af2ad0074f3aa8431f431bca352407019c Mon Sep 17 00:00:00 2001 From: Simon Chow Date: Tue, 20 Feb 2024 16:22:20 -0500 Subject: [PATCH 2/2] add import --- dags/dbt_sdf_marts_dag.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/dbt_sdf_marts_dag.py b/dags/dbt_sdf_marts_dag.py index a448605d..ab574611 100644 --- a/dags/dbt_sdf_marts_dag.py +++ b/dags/dbt_sdf_marts_dag.py @@ -4,7 +4,7 @@ from kubernetes.client import models as k8s from stellar_etl_airflow.build_cross_dependency_task import build_cross_deps from stellar_etl_airflow.build_dbt_task import dbt_task -from stellar_etl_airflow.default import get_default_dag_args +from stellar_etl_airflow.default import get_default_dag_args, init_sentry init_sentry()