diff --git a/models/streamline/silver/_24_hour_lookback.sql b/models/streamline/silver/_24_hour_lookback.sql new file mode 100644 index 0000000..e9d060f --- /dev/null +++ b/models/streamline/silver/_24_hour_lookback.sql @@ -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 + ) diff --git a/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql b/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql index 2018342..dcde7ff 100644 --- a/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql +++ b/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql @@ -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,