Skip to content

Commit

Permalink
(#1744) add copy grants option for Snowflake
Browse files Browse the repository at this point in the history
  • Loading branch information
Carolus-Holman committed Sep 17, 2019
1 parent 5dc776f commit 226247d
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
3 changes: 2 additions & 1 deletion plugins/snowflake/dbt/adapters/snowflake/impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,8 @@ class SnowflakeAdapter(SQLAdapter):
ConnectionManager = SnowflakeConnectionManager

AdapterSpecificConfigs = frozenset(
{"transient", "cluster_by", "automatic_clustering", "secure"}
{"transient", "cluster_by", "automatic_clustering", "secure",
"copy_grants"}
)

@classmethod
Expand Down
8 changes: 5 additions & 3 deletions plugins/snowflake/dbt/include/snowflake/macros/adapters.sql
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
{%- set transient = config.get('transient', default=true) -%}
{%- set cluster_by_keys = config.get('cluster_by', default=none) -%}
{%- set enable_automatic_clustering = config.get('automatic_clustering', default=false) -%}
{%- set copy_grants = config.get('copy_grants', default=false) -%}
{%- if cluster_by_keys is not none and cluster_by_keys is string -%}
{%- set cluster_by_keys = [cluster_by_keys] -%}
{%- endif -%}
Expand All @@ -15,8 +16,8 @@
temporary
{%- elif transient -%}
transient
{%- endif %} table {{ relation }}
as (
{%- endif %} table {{ relation }} {% if copy_grants and not temporary -%} copy grants {%- endif %} as
(
{%- if cluster_by_string is not none -%}
select * from(
{{ sql }}
Expand All @@ -36,9 +37,10 @@

{% macro snowflake__create_view_as(relation, sql) -%}
{%- set secure = config.get('secure', default=false) -%}
{%- set copy_grants = config.get('copy_grants', default=false) -%}
create or replace {% if secure -%}
secure
{%- endif %} view {{ relation }} as (
{%- endif %} view {{ relation }} {% if copy_grants -%} copy grants {%- endif %} as (
{{ sql }}
);
{% endmacro %}
Expand Down

0 comments on commit 226247d

Please sign in to comment.