fix default tests

Author: Michael Myaskovsky

macros/edr/data_monitoring/monitors_query/column_monitoring_query.sql

@@ -94,7 +94,33 @@
     ),
 
     column_metrics_unpivot as (
-        {{ elementary.get_column_metrics_unpivot_query(column_metrics, column_obj, metric_name_to_type, timestamp_column, dimensions) }}
+       {%- if column_metrics %}
+        {% for metric_name, metric_type in metric_name_to_type.items() %}
+            select
+                {{ elementary.const_as_string(column_obj.name) }} as edr_column_name,
+                bucket_start,
+                bucket_end,
+                {% if timestamp_column %}
+                    {{ elementary.timediff("hour", "bucket_start", "bucket_end") }} as bucket_duration_hours,
+                {% else %}
+                    {{ elementary.null_int() }} as bucket_duration_hours,
+                {% endif %}
+                {% if dimensions | length > 0 %}
+                  {{ elementary.const_as_string(elementary.join_list(dimensions, separator='; ')) }} as dimension,
+                  {{ elementary.list_concat_with_separator(prefixed_dimensions, separator='; ') }} as dimension_value,
+                {% else %}
+                  {{ elementary.null_string() }} as dimension,
+                  {{ elementary.null_string() }} as dimension_value,
+                {% endif %}
+                {{ elementary.edr_cast_as_float(metric_type) }} as metric_value,
+                {{ elementary.edr_cast_as_string(elementary.edr_quote(metric_name)) }} as metric_name,
+                {{ elementary.edr_cast_as_string(elementary.edr_quote(metric_type)) }} as metric_type
+            from column_metrics where {{ metric_type }} is not null
+            {% if not loop.last %} union all {% endif %}
+        {%- endfor %}
+    {%- else %}
+        {{ elementary.empty_table([('edr_column_name','string'),('bucket_start','timestamp'),('bucket_end','timestamp'),('bucket_duration_hours','int'),('dimension','string'),('dimension_value','string'),('metric_name','string'),('metric_type','string'),('metric_value','float')]) }}
+    {%- endif %}
     ),
 
     metrics_final as (

macros/edr/data_monitoring/monitors_query/dimension_monitoring_query.sql

@@ -202,8 +202,9 @@
                 {{ elementary.null_timestamp() }} as bucket_start,
                 bucket_end,
                 {{ elementary.null_int() }} as bucket_duration_hours,
-                {{ elementary.null_string() }} as dimension,
-                {{ elementary.null_string() }} as dimension_value,
+                
+                {{ elementary.const_as_string(dimensions_string) }} as dimension,
+                dimension_value,
                 {{ elementary.dict_to_quoted_json(metric_properties) }} as metric_properties
             from row_count
         )

macros/edr/tests/test_dimension_anomalies.sql

@@ -1,6 +1,6 @@
 {% test dimension_anomalies(model, dimensions, timestamp_column, where_expression, anomaly_sensitivity, anomaly_direction, min_training_set_size, time_bucket, days_back, backfill_days, seasonality, sensitivity,ignore_small_changes, fail_on_zero, detection_delay, anomaly_exclude_metrics, detection_period, training_period, exclude_final_results) %}
     {{ config(tags = ['elementary-tests']) }}
-    {%- if execute and elementary.is_test_command()%}
+    {%- if execute and elementary.is_test_command() and elementary.is_elementary_enabled() %}
         {% set model_relation = elementary.get_model_relation_for_test(model, context["model"]) %}
         {% if not model_relation %}
             {{ exceptions.raise_compiler_error("Unsupported model: " ~ model ~ " (this might happen if you override 'ref' or 'source')") }}

macros/edr/tests/test_table_anomalies.sql

@@ -1,6 +1,6 @@
 {% test table_anomalies(model, table_anomalies, timestamp_column, where_expression, anomaly_sensitivity, anomaly_direction, min_training_set_size, time_bucket, days_back, backfill_days, seasonality, mandatory_params=none, event_timestamp_column=none, freshness_column=none, sensitivity=none, ignore_small_changes={"spike_failure_percent_threshold": none, "drop_failure_percent_threshold": none}, fail_on_zero=false, detection_delay=none, anomaly_exclude_metrics=none, detection_period=none, training_period=none) %}
     {{ config(tags = ['elementary-tests']) }}
-    {%- if execute and elementary.is_test_command() %}
+    {%- if execute and elementary.is_test_command() and elementary.is_elementary_enabled()  %}
         {% set model_relation = elementary.get_model_relation_for_test(model, context["model"]) %}
         {% if not model_relation %}
             {{ exceptions.raise_compiler_error("The test has unsupported configuration, please contact Elementary support") }}