fix(incremental): replicated delete_insert

Savid · Jan 17, 2024 · 6125272 · 6125272
1 parent c522eb3
commit 6125272
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dbt/include/clickhouse/macros/materializations/incremental/incremental.sql b/dbt/include/clickhouse/macros/materializations/incremental/incremental.sql
@@ -249,8 +249,8 @@
             delete from {{ existing_local }} {{ on_cluster_clause(existing_relation) }} where ({{ unique_key }}) in (select {{ unique_key }}
                                           from {{ inserting_relation }})
       {% else %}
-            delete from {{ existing_relation }} where ({{ unique_key }}) in (select {{ unique_key }}
-                                          from {{ inserting_relation }})
+          delete from {{ existing_relation }} {{ on_cluster_clause() }} where ({{ unique_key }}) in (select {{ unique_key }}
+                                              from {{ new_data_relation }})
       {% endif %}
       {%- if incremental_predicates %}
         {% for predicate in incremental_predicates %}