From 0f91c93c3f894c6e096b2bf9f9a8d31849a28f82 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Wed, 6 Aug 2025 12:43:32 -0400 Subject: [PATCH] fix inc --- .../nft/mints/silver__nft_mints_combined.sql | 31 ++++++++++++++----- 1 file changed, 24 insertions(+), 7 deletions(-) diff --git a/models/silver/nft/mints/silver__nft_mints_combined.sql b/models/silver/nft/mints/silver__nft_mints_combined.sql index 12a5c34..b036b15 100644 --- a/models/silver/nft/mints/silver__nft_mints_combined.sql +++ b/models/silver/nft/mints/silver__nft_mints_combined.sql @@ -8,8 +8,30 @@ tags = ['noncore'] ) }} -WITH base AS ( +{% if execute %} +{% if is_incremental() %} +{% set min_bts_query %} + +SELECT + MIN(block_timestamp) :: DATE +FROM + {{ ref('silver__nft_mints_v2') }} +WHERE + _inserted_timestamp > ( + SELECT + MAX(_inserted_timestamp) modified_timestamp + FROM + {{ this }} + ) {% endset %} + {% set min_bts = run_query(min_bts_query) [0] [0] %} + {% if not min_bts or min_bts == 'None' %} + {% set min_bts = '2099-01-01' %} + {% endif %} +{% endif %} +{% endif %} + +WITH base AS ( SELECT * FROM @@ -69,12 +91,7 @@ WHERE success {% if is_incremental() %} -AND _inserted_timestamp >= ( - SELECT - MAX(_inserted_timestamp) - FROM - {{ this }} -) +AND block_timestamp :: DATE >= '{{ min_bts }}' {% endif %} ) SELECT