added test results

Author: arbiv

macros/edr/dbt_artifacts/upload_dbt_groups.sql

@@ -1,6 +1,7 @@
 {%- macro upload_dbt_groups(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation('dbt_groups') %}
     {% if execute and relation %}
+        {# % do debug() % #}
         {% set groups = graph.groups.values() | selectattr('resource_type', '==', 'group') %}
         {% do elementary.upload_artifacts_to_table(relation, groups, elementary.flatten_group, should_commit=should_commit, metadata_hashes=metadata_hashes) %}
     {%- endif -%}

macros/edr/dbt_artifacts/upload_run_results.sql

@@ -31,7 +31,8 @@
                                                                        ('query_id', 'string'),
                                                                        ('thread_id', 'string'),
                                                                        ('materialization', 'string'),
-                                                                       ('adapter_response', 'string')
+                                                                       ('adapter_response', 'string'),
+                                                                       ('group_name', 'string'),
                                                                        ]) %}
     {{ return(dbt_run_results_empty_table_query) }}
 {% endmacro %}
@@ -61,7 +62,8 @@
         'query_id': run_result_dict.get('adapter_response', {}).get('query_id'),
         'thread_id': run_result_dict.get('thread_id'),
         'materialization': config_dict.get('materialized'),
-        'adapter_response': run_result_dict.get('adapter_response', {})
+        'adapter_response': run_result_dict.get('adapter_response', {}),
+        'group_name': config_dict.get('group'),
     } %}
 
     {% set timings = elementary.safe_get_with_default(run_result_dict, 'timing', []) %}

models/edr/run_results/model_run_results.sql

@@ -31,6 +31,7 @@ SELECT
     run_results.compiled_code,
     run_results.adapter_response,
     run_results.thread_id,
+    run_results.group_name,
     models.database_name,
     models.schema_name,
     coalesce(run_results.materialization, models.materialization) as materialization,

models/edr/run_results/seed_run_results.sql

@@ -31,6 +31,7 @@ SELECT
     run_results.compiled_code,
     run_results.adapter_response,
     run_results.thread_id,
+    run_results.group_name,
     seeds.database_name,
     seeds.schema_name,
     run_results.materialization,

models/edr/run_results/snapshot_run_results.sql

@@ -31,6 +31,7 @@ SELECT
     run_results.compiled_code,
     run_results.adapter_response,
     run_results.thread_id,
+    run_results.group_name,
     snapshots.database_name,
     snapshots.schema_name,
     coalesce(run_results.materialization, snapshots.materialization) as materialization,