From 6434a6118a0cc6978b178a89edaa4e7e7b552771 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Sat, 12 Oct 2024 00:22:19 -0400 Subject: [PATCH] .. --- models/silver/core/silver__msg_attributes.sql | 2 +- models/silver/core/silver__msgs.sql | 2 +- models/silver/core/silver__transactions.sql | 2 +- models/silver/core/silver__transactions_final.sql | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/models/silver/core/silver__msg_attributes.sql b/models/silver/core/silver__msg_attributes.sql index 3f04d1a..6bcfe53 100644 --- a/models/silver/core/silver__msg_attributes.sql +++ b/models/silver/core/silver__msg_attributes.sql @@ -1,6 +1,6 @@ {{ config( materialized = 'incremental', - incremental_predicates = ["COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE) from " ~ generate_tmp_view_name(this) ~ ")"], + incremental_predicates = ['COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE -3) from ' ~ generate_tmp_view_name(this) ~ ')'], unique_key = ["tx_id","msg_index","attribute_index"], incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], diff --git a/models/silver/core/silver__msgs.sql b/models/silver/core/silver__msgs.sql index 38456ec..87a96bd 100644 --- a/models/silver/core/silver__msgs.sql +++ b/models/silver/core/silver__msgs.sql @@ -1,6 +1,6 @@ {{ config( materialized = 'incremental', - incremental_predicates = ["COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE) from " ~ generate_tmp_view_name(this) ~ ")"], + incremental_predicates = ['COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE -3) from ' ~ generate_tmp_view_name(this) ~ ')'], unique_key = ["tx_id","msg_index"], incremental_strategy = 'merge', merge_exclude_columns = ["inserted_timestamp"], diff --git a/models/silver/core/silver__transactions.sql b/models/silver/core/silver__transactions.sql index 173fc9d..33130f2 100644 --- a/models/silver/core/silver__transactions.sql +++ b/models/silver/core/silver__transactions.sql @@ -1,6 +1,6 @@ {{ config( materialized = 'incremental', - incremental_predicates = ["COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE) from " ~ generate_tmp_view_name(this) ~ ")"], + incremental_predicates = ['COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE -3) from ' ~ generate_tmp_view_name(this) ~ ')'], unique_key = "tx_id", incremental_strategy = 'merge', merge_exclude_columns = ["inserted_timestamp"], diff --git a/models/silver/core/silver__transactions_final.sql b/models/silver/core/silver__transactions_final.sql index 483fa6b..61c6f7f 100644 --- a/models/silver/core/silver__transactions_final.sql +++ b/models/silver/core/silver__transactions_final.sql @@ -1,6 +1,6 @@ {{ config( materialized = 'incremental', - incremental_predicates = ['DBT_INTERNAL_DEST.block_timestamp::DATE >= (select min(block_timestamp::DATE -3) from ' ~ generate_tmp_view_name(this) ~ ')'], + incremental_predicates = ['COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE -3) from ' ~ generate_tmp_view_name(this) ~ ')'], unique_key = "tx_id", incremental_strategy = 'merge', merge_exclude_columns = ["inserted_timestamp"],