|
66 | 66 | {{ return (graph.nodes[node_id] if node_id in graph.nodes else graph.sources[node_id]) }} |
67 | 67 | {% endmacro %} |
68 | 68 |
|
| 69 | +{% macro has_value(v) %} |
| 70 | + {{ return (v is defined and v is not none) }} |
| 71 | +{% endmacro %} |
| 72 | + |
69 | 73 | {% macro model_node (node) %} |
70 | 74 | {% set graph_nodes = graph.nodes.values() | |
71 | 75 | selectattr('resource_type', 'in', ['model', 'snapshot', 'seed']) | |
72 | 76 | selectattr('package_name', 'equalto', node.package_name) | |
73 | 77 | selectattr('name', 'equalto', node.name) | |
74 | 78 | list %} |
75 | 79 | {% if graph_nodes | length > 0 %} |
76 | | - {% if node.version is defined and node.version is not none %} |
| 80 | + {% if dbt_unit_testing.has_value(node.version) %} |
77 | 81 | {% set graph_nodes = graph_nodes | selectattr('version', 'equalto', node.version) | list %} |
78 | 82 | {% else %} |
79 | 83 | {% set latest_version = graph_nodes[0].latest_version %} |
80 | | - {% if latest_version is defined and latest_version is not none %} |
| 84 | + {% if dbt_unit_testing.has_value(latest_version) %} |
81 | 85 | {% set graph_nodes = graph_nodes | selectattr('version', 'equalto', latest_version) | list %} |
82 | 86 | {% endif %} |
83 | 87 | {% endif %} |
84 | 88 | {% endif %} |
85 | 89 | {% if graph_nodes | length == 0 %} |
86 | | - {% set node_version = '_v' ~ node.version if node.version is defined and node.version is not none else '' %} |
| 90 | + {% set node_version = '_v' ~ node.version if dbt_unit_testing.has_value(node.version) else '' %} |
87 | 91 | {{ dbt_unit_testing.raise_error("Node " ~ node.package_name ~ "." ~ node.name ~ node_version ~ " not found.") }} |
88 | 92 | {% endif %} |
89 | 93 | {% set graph_node = graph_nodes[0] %} |
|
0 commit comments