diff --git a/dbt_project.yml b/dbt_project.yml index a4dcb97..2bc01d4 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -29,6 +29,7 @@ vars: exclude_packages: ["elementary"] airflow_start_timestamp: "{{ env_var('AIRFLOW_START_TIMESTAMP', '2000-01-01') }}" + is_singular_airflow_task: "{{ env_var('IS_SINGULAR_AIRFLOW_TASK', 'false') }}" # Configuring models # Full documentation: https://docs.getdbt.com/docs/configuring-models diff --git a/tests/anomaly_detection_trade_count.sql b/tests/anomaly_detection_trade_count.sql index 672efd2..9ff7c26 100644 --- a/tests/anomaly_detection_trade_count.sql +++ b/tests/anomaly_detection_trade_count.sql @@ -1,7 +1,7 @@ {{ config( severity="warn" , tags=["singular_test"] - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/anomaly_detection_trade_volume.sql b/tests/anomaly_detection_trade_volume.sql index da330fb..8d3b256 100644 --- a/tests/anomaly_detection_trade_volume.sql +++ b/tests/anomaly_detection_trade_volume.sql @@ -1,7 +1,7 @@ {{ config( severity="warn" , tags=["singular_test"] - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/bucketlist_db_size_check.sql b/tests/bucketlist_db_size_check.sql index 165ad77..564e0c8 100644 --- a/tests/bucketlist_db_size_check.sql +++ b/tests/bucketlist_db_size_check.sql @@ -1,7 +1,7 @@ {{ config( severity="error" , tags=["singular_test"] - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/eho_by_ops.sql b/tests/eho_by_ops.sql index adcb91a..0b6929a 100644 --- a/tests/eho_by_ops.sql +++ b/tests/eho_by_ops.sql @@ -2,7 +2,7 @@ severity="error" , tags=["singular_test"] , meta={"alert_suppression_interval": 24} - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/ledger_sequence_increment.sql b/tests/ledger_sequence_increment.sql index 65cb203..01432b4 100644 --- a/tests/ledger_sequence_increment.sql +++ b/tests/ledger_sequence_increment.sql @@ -1,7 +1,7 @@ {{ config( severity="warn" , tags=["singular_test"] - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = ('{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/num_txns_and_ops.sql b/tests/num_txns_and_ops.sql index 6b6fa9e..976db89 100644 --- a/tests/num_txns_and_ops.sql +++ b/tests/num_txns_and_ops.sql @@ -1,7 +1,7 @@ {{ config( severity="error" , tags=["singular_test"] - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }} diff --git a/tests/sorobon_surge_pricing_check.sql b/tests/sorobon_surge_pricing_check.sql index d3ed353..85bb15d 100644 --- a/tests/sorobon_surge_pricing_check.sql +++ b/tests/sorobon_surge_pricing_check.sql @@ -2,7 +2,7 @@ severity="warn" , tags=["singular_test"] , meta={"alert_suppression_interval": 24} - , enabled = (target.name == "prod" and is_singular_airflow_task == "true") + , enabled = (target.name == "prod" and '{{ var("is_singular_airflow_task") }}' == "true") ) }}