lookback (#363)

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
+    )

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,