From ec11e4cad2332a8ed0765ae56ce9216c810d5227 Mon Sep 17 00:00:00 2001 From: Yaroslav Nosa Date: Tue, 7 Jul 2020 19:45:11 +0300 Subject: [PATCH] aws_sns_topic property needs to be quoted in create or replace pipe statement according to doc --- macros/external/create_snowpipe.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/macros/external/create_snowpipe.sql b/macros/external/create_snowpipe.sql index 0811490e..62c8376d 100644 --- a/macros/external/create_snowpipe.sql +++ b/macros/external/create_snowpipe.sql @@ -58,7 +58,7 @@ {# https://docs.snowflake.com/en/sql-reference/sql/create-pipe.html #} create or replace pipe {{source(source_node.source_name, source_node.name)}} {% if snowpipe.auto_ingest -%} auto_ingest = {{snowpipe.auto_ingest}} {%- endif %} - {% if snowpipe.aws_sns_topic -%} aws_sns_topic = {{snowpipe.aws_sns_topic}} {%- endif %} + {% if snowpipe.aws_sns_topic -%} aws_sns_topic = '{{snowpipe.aws_sns_topic}}' {%- endif %} {% if snowpipe.integration -%} integration = '{{snowpipe.integration}}' {%- endif %} as {{ dbt_external_tables.snowflake_get_copy_sql(source_node) }}