Sane as dbt-labs#3003. But for postgres

mikaelene · Jan 11, 2021 · bc01572 · bc01572
1 parent ccd2064
commit bc01572
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/plugins/postgres/dbt/include/postgres/macros/materializations/snapshot_merge.sql b/plugins/postgres/dbt/include/postgres/macros/materializations/snapshot_merge.sql
@@ -6,14 +6,7 @@
     set dbt_valid_to = DBT_INTERNAL_SOURCE.dbt_valid_to
     from {{ source }} as DBT_INTERNAL_SOURCE
     where DBT_INTERNAL_SOURCE.dbt_scd_id::text = {{ target }}.dbt_scd_id::text
-      and DBT_INTERNAL_SOURCE.dbt_change_type::text = 'update'::text
-      and {{ target }}.dbt_valid_to is null;
-
-    update {{ target }}
-    set dbt_valid_to = DBT_INTERNAL_SOURCE.dbt_valid_to
-    from {{ source }} as DBT_INTERNAL_SOURCE
-    where DBT_INTERNAL_SOURCE.dbt_scd_id::text = {{ target }}.dbt_scd_id::text
-      and DBT_INTERNAL_SOURCE.dbt_change_type::text = 'delete'::text
+      and DBT_INTERNAL_SOURCE.dbt_change_type::text in ('update'::text, 'delete'::text)
       and {{ target }}.dbt_valid_to is null;
 
     insert into {{ target }} ({{ insert_cols_csv }})