validate_aggregate_coherence.sql

{% macro validate_aggregate_coherence(metric_aggregate, calculation_aggregate) %}
    {% set allowlist = metrics.get_metric_allowlist()[metric_aggregate] %}

    {% if (calculation_aggregate not in allowlist) %}
        {% do exceptions.raise_compiler_error("Can't calculate secondary aggregate " ~ calculation_aggregate ~ " when metric's aggregation is " ~ metric_aggregate ~ ". Allowed options are " ~ allowlist ~ ".") %}
    {% endif %}
{% endmacro %}

{% macro get_metric_allowlist() %}
    {{ return(adapter.dispatch('get_metric_allowlist', 'metrics')()) }}
{% endmacro %}

{% macro default__get_metric_allowlist() %}
    {# Keys are the primary aggregation, values are the permitted aggregations to run in secondary calculations. #}
    {% do return ({
        "average": ['min', 'max'],
        "count": ['min', 'max', 'sum', 'average'],
        "count_distinct": ['min', 'max', 'sum', 'average'],
        "sum": ['min', 'max', 'sum', 'average'],
        "max": ['min', 'max', 'sum', 'average'],
        "min": ['min', 'max', 'sum', 'average'],
    }) %}
{% endmacro %}