This commit is contained in:
drethereum 2025-04-01 09:48:26 -06:00
parent 1143c8da81
commit 8876e510cb
3 changed files with 27 additions and 3 deletions

View File

@ -15,13 +15,21 @@
tags = ['streamline_testnet_realtime']
) }}
WITH to_do AS (
WITH last_3_days AS (
SELECT block_number
FROM {{ ref("_testnet_block_lookback") }}
),
to_do AS (
SELECT block_number
FROM {{ ref("streamline__testnet_blocks") }}
WHERE block_number IS NOT NULL
AND block_number >= (SELECT block_number FROM last_3_days)
EXCEPT
SELECT block_number
FROM {{ ref("streamline__testnet_blocks_complete") }} b
INNER JOIN {{ ref("streamline__testnet_transactions_complete") }} t USING(block_number)
WHERE 1=1
AND block_number >= (SELECT block_number FROM last_3_days)
),
ready_blocks AS (
SELECT block_number

View File

@ -15,12 +15,20 @@
tags = ['streamline_testnet_realtime']
) }}
WITH to_do AS (
WITH last_3_days AS (
SELECT block_number
FROM {{ ref("_testnet_block_lookback") }}
),
to_do AS (
SELECT block_number
FROM {{ ref("streamline__testnet_blocks") }}
WHERE block_number IS NOT NULL
AND block_number >= (SELECT block_number FROM last_3_days)
EXCEPT
SELECT block_number
FROM {{ ref("streamline__testnet_receipts_complete") }}
WHERE 1=1
AND block_number >= (SELECT block_number FROM last_3_days)
),
ready_blocks AS (
SELECT block_number

View File

@ -15,12 +15,20 @@
tags = ['streamline_testnet_realtime']
) }}
WITH to_do AS (
WITH last_3_days AS (
SELECT block_number
FROM {{ ref("_testnet_block_lookback") }}
),
to_do AS (
SELECT block_number
FROM {{ ref("streamline__testnet_blocks") }}
WHERE block_number IS NOT NULL
AND block_number >= (SELECT block_number FROM last_3_days)
EXCEPT
SELECT block_number
FROM {{ ref("streamline__testnet_traces_complete") }}
WHERE 1=1
AND block_number >= (SELECT block_number FROM last_3_days)
),
ready_blocks AS (
SELECT block_number