Skip to content
This repository was archived by the owner on Mar 6, 2026. It is now read-only.
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions dbt_project.yml
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
name: 'dbt_snowflake_query_tags'
version: '2.5.4'
config-version: 2
flags:
require_generic_test_arguments_property: true # add dbt-autoifix suggestion
17 changes: 0 additions & 17 deletions macros/query_tags.sql → macros/default__set_query_tag.sql
Original file line number Diff line number Diff line change
@@ -1,7 +1,3 @@
{% macro set_query_tag(extra = {}) -%}
{{ return(adapter.dispatch('set_query_tag', 'dbt_snowflake_query_tags')(extra=extra)) }}
{%- endmacro %}

{% macro default__set_query_tag(extra = {}) -%}
{# Get session level query tag #}
{% set original_query_tag = get_current_query_tag() %}
Expand Down Expand Up @@ -64,16 +60,3 @@
{{ return(original_query_tag)}}
{% endmacro %}

{% macro unset_query_tag(original_query_tag) -%}
{{ return(adapter.dispatch('unset_query_tag', 'dbt_snowflake_query_tags')(original_query_tag)) }}
{%- endmacro %}

{% macro default__unset_query_tag(original_query_tag) -%}
{% if original_query_tag %}
{{ log("Resetting query_tag to '" ~ original_query_tag ~ "'.") }}
{% do run_query("alter session set query_tag = '{}'".format(original_query_tag)) %}
{% else %}
{{ log("No original query_tag, unsetting parameter.") }}
{% do run_query("alter session unset query_tag") %}
{% endif %}
{% endmacro %}
10 changes: 10 additions & 0 deletions macros/default__unset_query_tag.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
{% macro default__unset_query_tag(original_query_tag) -%}
{% if original_query_tag %}
{{ log("Resetting query_tag to '" ~ original_query_tag ~ "'.") }}
{% do run_query("alter session set query_tag = '{}'".format(original_query_tag)) %}
{% else %}
{{ log("No original query_tag, unsetting parameter.") }}
{% do run_query("alter session unset query_tag") %}
{% endif %}
{% endmacro %}

4 changes: 4 additions & 0 deletions macros/set_query_tag.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
{% macro set_query_tag(extra = {}) -%}
{{ return(adapter.dispatch('set_query_tag', 'dbt_snowflake_query_tags')(extra=extra)) }}
{%- endmacro %}

4 changes: 4 additions & 0 deletions macros/unset_query_tag.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
{% macro unset_query_tag(original_query_tag) -%}
{{ return(adapter.dispatch('unset_query_tag', 'dbt_snowflake_query_tags')(original_query_tag)) }}
{%- endmacro %}

Loading