adjust incremental and fix decoder (#255)

This commit is contained in:
Sam 2025-02-12 23:20:21 +08:00 committed by GitHub
parent 90816fc263
commit 5d1b3f5f46
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 33 additions and 12 deletions

View File

@ -59,9 +59,10 @@ FROM
LEFT JOIN {{ ref('silver__contracts') }} C USING (contract_address)
{% if is_incremental() %}
AND l.modified_timestamp > (
SELECT
COALESCE(MAX(modified_timestamp), '2000-01-01' :: TIMESTAMP)
FROM
{{ this }})
{% endif %}
WHERE
l.modified_timestamp > (
SELECT
COALESCE(MAX(modified_timestamp), '2000-01-01' :: TIMESTAMP)
FROM
{{ this }})
{% endif %}

View File

@ -82,6 +82,16 @@ tokens_registered AS (
pools_registered
)
AND tx_succeeded
{% if is_incremental() %}
AND _inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp) - INTERVAL '12 hours'
FROM
{{ this }}
)
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
function_sigs AS (
SELECT

View File

@ -105,6 +105,16 @@ logs AS(
FROM
traces
)
{% if is_incremental() %}
AND _inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp) - INTERVAL '12 hours'
FROM
{{ this }}
)
AND _inserted_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
)
SELECT
l.tx_hash,

View File

@ -84,7 +84,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
raw_logs_event_index_fill AS (
@ -1887,7 +1887,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
nft_transfer_operator AS (
@ -1929,7 +1929,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
final_seaport AS (

View File

@ -82,7 +82,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
raw_logs_event_index_fill AS (
@ -1885,7 +1885,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
nft_transfer_operator AS (
@ -1927,7 +1927,7 @@ AND modified_timestamp >= (
FROM
{{ this }}
)
AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
AND block_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
),
final_seaport AS (