add select tags

This commit is contained in:
Jack Forgash 2023-09-07 15:45:35 -06:00
parent 1940dfe33c
commit 4adff0a8a6
3 changed files with 13 additions and 11 deletions

View File

@ -58,3 +58,14 @@ on-run-start:
on-run-end:
- "{{ apply_meta_as_tags(results) }}"
dispatch:
- macro_namespace: dbt
search_order:
- osmosis-models
- dbt_snowflake_query_tags
- dbt
query-comment:
comment: '{{ dbt_snowflake_query_tags.get_query_comment(node) }}'
append: true # Snowflake removes prefixed comments.

View File

@ -1,11 +0,0 @@
{% macro set_query_tag() -%}
{% set new_json = {"repo":project_name, "object":this.table, "profile":target.profile_name, "env":target.name, "existing_tag":get_current_query_tag() } %}
{% set new_query_tag = tojson(new_json) | as_text %}
{% if new_query_tag %}
{% set original_query_tag = get_current_query_tag() %}
{{ log("Setting query_tag to '" ~ new_query_tag ~ "'. Will reset to '" ~ original_query_tag ~ "' after materialization.") }}
{% do run_query("alter session set query_tag = '{}'".format(new_query_tag)) %}
{{ return(original_query_tag)}}
{% endif %}
{{ return(none)}}
{% endmacro %}

View File

@ -3,3 +3,5 @@ packages:
version: [">=0.4.0", "<0.9.0"]
- git: https://github.com/FlipsideCrypto/fsc-utils.git
revision: v1.3.0
- package: get-select/dbt_snowflake_query_tags
version: [">=2.0.0", "<3.0.0"]