|
40 | 40 |
|
41 | 41 | {% if any_refs %} |
42 | 42 | {% set name = any_refs[0] %} |
43 | | - {% set node_name = re_data.priv_full_name_from_depends(el.node, name) %} |
| 43 | + {% set node_name = re_data.priv_full_name_from_depends(el.node, name, "model") %} |
44 | 44 | {% set schema = graph.nodes.get(node_name)['schema'] %} |
45 | 45 | {% set database = graph.nodes.get(node_name)['database'] %} |
46 | | - {% set table_name = (database + '.' + schema + '.' + name) | lower %} |
47 | | - |
| 46 | + {% set table_name = (database + '.' + schema + '.' + name) | lower %} |
| 47 | + |
48 | 48 | {% elif any_source %} |
49 | 49 | {% set package_name = any_source[0][0] %} |
50 | 50 | {% set name = any_source[0][1] %} |
51 | | - {% set node_name = re_data.priv_full_name_from_depends(el.node, name) %} |
| 51 | + {% set node_name = re_data.priv_full_name_from_depends(el.node, name, "source") %} |
52 | 52 | {% set schema = graph.sources.get(node_name)['schema'] %} |
53 | 53 | {% set database = graph.sources.get(node_name)['database'] %} |
54 | 54 | {% set table_name = (database + '.' + schema + '.' + name) | lower %} |
|
98 | 98 |
|
99 | 99 | {% endmacro %} |
100 | 100 |
|
101 | | -{% macro priv_full_name_from_depends(node, name) %} |
| 101 | +{% macro priv_full_name_from_depends(node, name, type) %} |
102 | 102 |
|
103 | 103 | {% for full_name in node.depends_on.nodes %} |
104 | 104 | {% set node_name = full_name.split('.')[-1] %} |
105 | | - {% if node_name == name %} |
| 105 | + {% set node_type = full_name.split('.')[0] %} |
| 106 | + {% if node_name == name and node_type == type %} |
106 | 107 | {{ return(full_name) }} |
107 | 108 | {% endif %} |
108 | 109 | {% endfor %} |
|
0 commit comments