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) }}