Use get_snapshot_table_column_names macro

dbt-labs · Sep 16, 2024 · cc960f3 · cc960f3
1 parent 402265a
commit cc960f3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dbt/include/spark/macros/materializations/snapshot.sql b/dbt/include/spark/macros/materializations/snapshot.sql
@@ -135,9 +135,9 @@
 
   {% else %}
 
-      {% set snapshot_table_column_names = config.get("snapshot_table_column_names") %}
+      {% set stcn = config.get("snapshot_table_column_names") or get_snapshot_table_column_names() %}
 
-      {{ adapter.valid_snapshot_target(target_relation, snapshot_table_column_names) }}
+      {{ adapter.valid_snapshot_target(target_relation, stcn) }}
 
       {% set staging_table = spark_build_snapshot_staging_table(strategy, sql, target_relation) %}