dbt-f2dq/macros/utils/generate_alert_message.sql

{% macro generate_anomaly_message(column_name, metric, last_value, last_avg) -%}
  {{ return(adapter.dispatch('generate_anomaly_message', 'f2dq')(column_name, metric, last_value, last_avg)) }}
{%- endmacro %}

{% macro default__generate_anomaly_message(column_name, metric, last_value, last_avg) %}

    case when {{ column_name }} != '' then metric || '(' || column_name || ')'
    else metric
    end 
    || ' is ' ||
    {{ to_2dp( percentage_formula('last_value - last_avg', last_avg) ) }}
    || '% ' ||
    {{ comparison_text(last_value, last_avg) }}
    || ' average.'
{% endmacro %}

{% macro to_2dp(val) %}
    {{ adapter.dispatch('to_2dp', 'f2dq')(val) }}
{% endmacro %}

{% macro default__to_2dp(val) %}
    trim(to_char({{ val }}, '9999999999999999990D00'))
{% endmacro %}

{% macro bigquery__to_2dp(val) %}
    format('%.2f', {{ val }})
{% endmacro %}

{% macro seconds_to_hours(val) %}
    cast({{ val }} as {{ numeric_type() }}) / 3600
{% endmacro %}

{% macro generate_metric_value_text(metric, value) %}
    case 
        when {{ metric }} = 'freshness' 
            then cast({{ to_2dp(seconds_to_hours(value)) }} as {{ string_type() }}) || ' hours'
        when {{ regex_match_expression(metric, 'percent') }} 
            then cast({{ to_2dp(value) }} as {{ string_type() }}) || '%'
        when {{ regex_match_expression(metric, 'count') }} 
            then cast({{ value }} as {{ string_type() }})
        else cast({{ to_2dp(value) }} as {{ string_type() }})
    end

{% endmacro %}

{% macro generate_schema_change_message(operation, column_name, prev_column_name, prev_data_type, data_type, detected_time) %}
    case 
        when {{ operation }} = 'column_added'
            then 'column ' || {{ column_name }} || ' of type ' || {{ data_type }} || ' was added.'
        when {{ operation }} = 'column_removed'
            then 'column ' || {{ prev_column_name }} || ' of type ' || {{ prev_data_type }} || ' was removed.'
        when {{ operation }} = 'type_change'
            then {{ column_name }} || ' column data type was changed from ' || {{ prev_data_type }} || ' to ' || {{ data_type }} || '.'
        else ''
    end
{% endmacro %}

{% macro generate_failed_test_message(test_name, column_name) %}
    case 
        when {{ column_name }} is null
            then 'Test ' || {{ test_name }} || ' failed.'
        else
            'Test ' || {{ test_name }} || ' failed for column ' || {{ column_name }} || '.'
    end
{% endmacro %}