Skip to content

Commit 51f330e

Browse files
committed
bugfix - use correct flatten macro for test parent nodes
1 parent df232d4 commit 51f330e

File tree

2 files changed

+20
-1
lines changed

2 files changed

+20
-1
lines changed
Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{% macro flatten_node(node_dict) %}
2+
{% set resource_type = node_dict.get("resource_type") %}
3+
{% set flatten_func = {
4+
"model": elementary.flatten_model,
5+
"snapshot": elementary.flatten_model,
6+
"source": elementary.flatten_source,
7+
"seed": elementary.flatten_seed,
8+
"test": elementary.flatten_test,
9+
"group": elementary.flatten_group,
10+
"metric": elementary.flatten_metric,
11+
"exposure": elementary.flatten_exposure
12+
}.get(resource_type) %}
13+
14+
{% if not flatten_func %}
15+
{% do exceptions.raise_compiler_error("Unknown resource type: " ~ resource_type) %}
16+
{% endif %}
17+
18+
{% do return(flatten_func(node_dict)) %}
19+
{% endmacro %}

macros/edr/dbt_artifacts/upload_dbt_tests.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@
8282
{% set test_models_owners = [] %}
8383
{% set test_models_tags = [] %}
8484
{% for test_model_node in test_model_nodes %}
85-
{% set flatten_test_model_node = elementary.flatten_model(test_model_node) %}
85+
{% set flatten_test_model_node = elementary.flatten_node(test_model_node) %}
8686
{% set test_model_owner = flatten_test_model_node.get('owner') %}
8787
{% if test_model_owner %}
8888
{% if test_model_owner is string %}

0 commit comments

Comments
 (0)