Alter/Rename Dynamic Tables on full refresh (#1203)

Author: colin-rogers-dbt

dbt-snowflake/.changes/unreleased/Fixes-20250716-095518.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: Rename DT temp tables to avoid problematic drops
+time: 2025-07-16T09:55:18.719362-07:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "713"

dbt-snowflake/src/dbt/adapters/snowflake/relation.py

@@ -42,6 +42,7 @@ class SnowflakeRelation(BaseRelation):
             {
                 SnowflakeRelationType.Table,  # type: ignore
                 SnowflakeRelationType.View,  # type: ignore
+                SnowflakeRelationType.DynamicTable,  # type: ignore
             }
         )
     )
@@ -60,6 +61,10 @@ class SnowflakeRelation(BaseRelation):
     def is_dynamic_table(self) -> bool:
         return self.type == SnowflakeRelationType.DynamicTable
 
+    @property
+    def is_materialized_view(self) -> bool:
+        return self.type == SnowflakeRelationType.DynamicTable
+
     @property
     def is_iceberg_format(self) -> bool:
         return self.table_format == constants.ICEBERG_TABLE_FORMAT

dbt-snowflake/src/dbt/include/snowflake/macros/relations/dynamic_table/rename.sql

@@ -0,0 +1,13 @@
+{%- macro snowflake__get_rename_materialized_view_sql(relation, new_name) -%}
+    /*
+    Rename or move a dynamic table to the new name.
+
+    Args:
+        relation: SnowflakeRelation - dynamic table relation to be renamed
+        new_name: Union[str, SnowflakeRelation] - new name for `relation`
+            if providing a string, the default database/schema will be used if that string is just an identifier
+            if providing a SnowflakeRelation, `render` will be used to produce a fully qualified name
+    Returns: templated string
+    */
+    alter dynamic table {{ relation }} rename to {{ new_name }}
+{%- endmacro -%}

dbt-snowflake/tests/functional/relation_tests/dynamic_table_tests/models.py

@@ -110,3 +110,30 @@
 ) }}
 select * from {{ ref('my_seed') }}
 """
+
+DYNAMIC_TABLE_CUSTOM_SCHEMA = """
+{{ config(
+    materialized='dynamic_table',
+    snowflake_warehouse='DBT_TESTING',
+    target_lag='30 minutes',
+    schema='custom_schema'
+) }}
+select * from {{ ref('simple_model') }}
+"""
+
+DYNAMIC_TABLE_CUSTOM_DB_SCHEMA = """
+{{ config(
+    materialized='dynamic_table',
+    snowflake_warehouse='DBT_TESTING',
+    target_lag='30 minutes',
+    schema='custom_schema'
+) }}
+select * from {{ ref('simple_model') }}
+"""
+
+SIMPLE_MODEL = """
+{{ config(
+    materialized='table'
+) }}
+SELECT 1 as id
+"""

dbt-snowflake/tests/functional/relation_tests/dynamic_table_tests/test_full_refresh_custom_schema.py

@@ -0,0 +1,26 @@
+import pytest
+
+from dbt.tests.util import run_dbt, run_dbt_and_capture
+
+from tests.functional.relation_tests.dynamic_table_tests import models
+from tests.functional.utils import query_relation_type
+
+
+class TestDynamicTableFullRefreshCustomSchema:
+
+    @pytest.fixture(scope="class", autouse=True)
+    def models(self):
+        return {
+            "simple_model.sql": models.SIMPLE_MODEL,
+            "custom_schema_dynamic_table.sql": models.DYNAMIC_TABLE_CUSTOM_SCHEMA,
+        }
+
+    def test_dynamic_table_full_refresh_with_custom_schema(self, project):
+        """Test that dynamic table full refresh works with custom schema configuration."""
+        # Initial run to create the dynamic table
+        run_dbt(["seed"])
+        run_dbt(["run"])
+
+        # Run full refresh - this was failing before the fix
+        run_dbt(["run", "--full-refresh"])
+        run_dbt(["run", "--full-refresh"])

dbt-snowflake/tests/unit/test_renamed_relations.py

@@ -13,5 +13,6 @@ def test_renameable_relation():
         {
             SnowflakeRelationType.Table,
             SnowflakeRelationType.View,
+            SnowflakeRelationType.DynamicTable,
         }
     )