Check both dbt_valid_to_current and null

dbt-labs · Sep 27, 2024 · 9defe6b · 9defe6b
1 parent a684080
commit 9defe6b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dbt/include/postgres/macros/materializations/snapshot_merge.sql b/dbt/include/postgres/macros/materializations/snapshot_merge.sql
@@ -10,7 +10,7 @@
     where DBT_INTERNAL_SOURCE.{{ columns.dbt_scd_id }}::text = {{ target }}.{{ columns.dbt_scd_id }}::text
       and DBT_INTERNAL_SOURCE.dbt_change_type::text in ('update'::text, 'delete'::text)
       {% if config.get("dbt_valid_to_current") %}
-        and {{ target }}.{{ columns.dbt_valid_to }} = {{ config.get('dbt_valid_to_current') }};
+        and ({{ target }}.{{ columns.dbt_valid_to }} = {{ config.get('dbt_valid_to_current') }} or {{ target }}.{{ columns.dbt_valid_to }} is null);
       {% else %}
         and {{ target }}.{{ columns.dbt_valid_to }} is null;
       {% endif %}