Skip to content

Commit bc5bc4a

Browse files
committed
use leading comments unless the adapter is Snowflake
1 parent 510ccf9 commit bc5bc4a

File tree

1 file changed

+16
-7
lines changed

1 file changed

+16
-7
lines changed

macros/utils/run_queries/run_query.sql

Lines changed: 16 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,5 @@
11
{% macro run_query(query, lowercase_column_names=True) %}
2-
{% set query_with_metadata %}
3-
{{ query }}
4-
/* --ELEMENTARY-METADATA-- {{ elementary.get_elementary_query_metadata() | tojson }} --END-ELEMENTARY-METADATA-- */
5-
{% endset %}
6-
{% do print(query_with_metadata) %}
7-
8-
{% set query_result = dbt.run_query(query_with_metadata) %}
2+
{% set query_result = dbt.run_query(elementary.format_query_with_metadata(query)) %}
93
{% if lowercase_column_names %}
104
{% set lowercased_column_names = {} %}
115
{% for column_name in query_result.column_names %}
@@ -17,6 +11,21 @@
1711
{% do return(query_result) %}
1812
{% endmacro %}
1913

14+
{% macro format_query_with_metadata(query) %}
15+
{% do return(adapter.dispatch('format_query_with_metadata', 'elementary')(query)) %}
16+
{% endmacro %}
17+
18+
{% macro default__format_query_with_metadata(query) %}
19+
/* --ELEMENTARY-METADATA-- {{ elementary.get_elementary_query_metadata() | tojson }} --END-ELEMENTARY-METADATA-- */
20+
{{ query }}
21+
{% endmacro %}
22+
23+
{% macro snowflake__format_query_with_metadata(query) %}
24+
{# Snowflake removes leading comments #}
25+
{{ query }}
26+
/* --ELEMENTARY-METADATA-- {{ elementary.get_elementary_query_metadata() | tojson }} --END-ELEMENTARY-METADATA-- */
27+
{% endmacro %}
28+
2029
{% macro get_elementary_query_metadata() %}
2130
{% set metadata = {
2231
"invocation_id": invocation_id,

0 commit comments

Comments
 (0)