Skip to content

Commit 679057a

Browse files
committed
feat: Add resource type option to generate_schema_baseline_test
1 parent f1602cf commit 679057a

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

macros/commands/generate_schema_baseline_test.sql

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
{% macro generate_schema_baseline_test(name=none, include_sources=True, include_models=False, fail_on_added=False, enforce_types=False, convert_to_lower=False) %}
1+
{% macro generate_schema_baseline_test(name=none, include_sources=True, include_models=False, fail_on_added=False, enforce_types=False, convert_to_lower=False, resource_type=none) %}
22
{% if name %}
3-
{{ generate_schema_baseline_test_for_node(name, fail_on_added=fail_on_added, enforce_types=enforce_types, convert_to_lower=convert_to_lower) }}
3+
{{ generate_schema_baseline_test_for_node(name, fail_on_added=fail_on_added, enforce_types=enforce_types, convert_to_lower=convert_to_lower, resource_type=resource_type) }}
44
{% else %}
55
{{ generate_schema_baseline_test_for_all_nodes(include_sources=include_sources, include_models=include_models,
66
fail_on_added=fail_on_added, enforce_types=enforce_types, convert_to_lower=convert_to_lower) }}
@@ -20,11 +20,10 @@
2020
{% endfor %}
2121
{% endmacro %}
2222

23-
{% macro generate_schema_baseline_test_for_node(node, fail_on_added=False, enforce_types=False, convert_to_lower=False) %}
23+
{% macro generate_schema_baseline_test_for_node(node, fail_on_added=False, enforce_types=False, convert_to_lower=False, resource_type=none) %}
2424
{% if node is string %}
2525
{% set node_name = node %}
26-
{% set node = elementary.get_node_by_name(node_name) %}
27-
26+
{% set node = elementary.get_node_by_name(node_name, resource_type) %}
2827
{% if not node %}
2928
{% do print("Could not find any model or source by the name '{}'!".format(node_name)) %}
3029
{% do return(none) %}
@@ -84,7 +83,7 @@ sources:
8483
{%- for param, param_val in test_params.items() %}
8584
{{param}}: {{param_val}}
8685
{%- endfor -%}
87-
{% endif -%}
86+
{% endif -%}
8887
{% endmacro %}
8988

9089
{% macro generate_schema_baseline_test_for_model(node, columns, test_params, convert_to_lower) %}

macros/utils/graph/get_node_by_name.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
{% macro get_node_by_name(name) %}
1+
{% macro get_node_by_name(name, resource_type=none) %}
22
{%- set nodes = elementary.get_nodes_from_graph() -%}
33
{% for node in nodes %}
4-
{% if node.name == name %}
4+
{% if node.name == name and (resource_type is none or node.resource_type == resource_type) %}
55
{% do return(node) %}
66
{% endif %}
77
{% endfor %}

0 commit comments

Comments
 (0)