flip/base-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/base-models.git synced 2026-02-06 15:36:47 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

lookback (#163)

Browse Source
This commit is contained in:
Austin 2024-04-12 10:48:26 -04:00 committed by GitHub
parent 6618d48cd5
commit 488dfa2ad7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 28 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
models/streamline/silver/_24_hour_lookback.sql Normal file
View File

@ -0,0 +1,26 @@
{{ config (
materialized = "ephemeral"
) }}
WITH max_time AS (
SELECT
MAX(block_timestamp) AS max_timestamp
FROM
{{ ref("silver__blocks") }}
)
SELECT
MIN(block_number) AS block_number
FROM
{{ ref("silver__blocks") }}
JOIN max_time
ON block_timestamp BETWEEN DATEADD(
'hour',
-25,
max_timestamp
)
AND DATEADD(
'hour',
-24,
max_timestamp
)

9
models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql
View File

@ -9,11 +9,7 @@ WITH look_back AS (
SELECT
block_number
FROM
{{ ref("_max_block_by_date") }}
qualify ROW_NUMBER() over (
ORDER BY
block_number DESC
) = 1
{{ ref("_24_hour_lookback") }}
)
SELECT
l.block_number,
@ -58,5 +54,4 @@ WHERE
FROM
look_back
)
AND _inserted_timestamp >= DATEADD('day', -2, CURRENT_DATE())
)
AND _inserted_timestamp >= DATEADD('day', -2, CURRENT_DATE()))