dbt-f2dq/models/alerts/f2dq_alerts.sql

select
    'anomaly' as type,
    {{ f2dq.clean_blacklist('table_name', ['"', '`'], '') }} as model,
    message,
    last_value_text as value,
    time_window_end
from
    {{ ref(var('f2dq:anomalies_filtered')) }}
union all

select
    'schema_change' as type,
    {{ f2dq.clean_blacklist('table_name', ['"', '`'], '') }} as model,
    {{ generate_schema_change_message('operation', 'column_name', 'prev_column_name', 'prev_data_type', 'data_type', 'detected_time') }} as message,
    '' as value,
    detected_time as time_window_end
from {{ ref('f2dq_schema_changes') }}

union all

select
    'test' as type,
    table_name as model,
    {{ generate_failed_test_message('test_name', 'column_name') }},
    status as value,
    run_at as time_window_end

from {{ ref('f2dq_test_history') }}
where
    status = 'Fail'
    or status = 'Error'
    {% if f2dq.f2dq_var('show_warns_as_alerts', false) %}
    or status = 'Warn'
    {% endif %}