perf(bridges): propagate block_time into layerzero deposits transfers scan (#9757)

Author: a-monteiro

dbt_subprojects/hourly_spellbook/macros/sector/bridges/layerzero_v1_deposits.sql

@@ -17,15 +17,17 @@ WITH send_calls AS (
     )
 
 , distinct_calls AS (
-    SELECT block_number
+    SELECT block_time
+    , block_number
     , tx_hash
     , MAX(call_send_index) AS max_call_send_index
     FROM send_calls
-    GROUP BY 1, 2
+    GROUP BY 1, 2, 3
     )
 
 , transfers AS (
-    SELECT block_number
+    SELECT block_time
+    , block_number
     , tx_hash
     , sender
     , recipient
@@ -36,7 +38,8 @@ WITH send_calls AS (
     , unique_key
     , rn
     FROM (
-        SELECT t.block_number
+        SELECT t.block_time
+        , t.block_number
         , t.tx_hash
         , t."from" AS sender
         , t.to AS recipient
@@ -45,11 +48,15 @@ WITH send_calls AS (
         , t.contract_address AS deposit_token_address
         , t.evt_index
         , t.unique_key
-        , ROW_NUMBER() OVER (PARTITION BY t.tx_hash ORDER BY COALESCE(t.trace_address, ARRAY[t.evt_index])) AS rn
+        -- block_time in the window partition keys is redundant for correctness (tx_hash
+        -- determines the block) but lets the planner propagate the incremental
+        -- block_time predicate below the window instead of scanning all history
+        , ROW_NUMBER() OVER (PARTITION BY t.block_time, t.block_number, t.tx_hash ORDER BY COALESCE(t.trace_address, ARRAY[t.evt_index])) AS rn
         , sc.max_call_send_index
         FROM {{ source('tokens_' + blockchain, 'transfers') }} t
         INNER JOIN {{ ref('bridges_layerzero_chain_indexes') }} i ON i.blockchain='{{blockchain}}'
-        INNER JOIN distinct_calls sc ON t.block_number=sc.block_number
+        INNER JOIN distinct_calls sc ON t.block_time=sc.block_time
+                AND t.block_number=sc.block_number
                 AND t.tx_hash=sc.tx_hash
                 AND t.to=i.endpoint_address
         )
@@ -75,7 +82,8 @@ SELECT distinct '{{blockchain}}' AS deposit_chain
 , sc.contract_address
 , {{ dbt_utils.generate_surrogate_key(['sc.tx_hash', 't.evt_index', 'sc.call_send_index']) }} as bridge_transfer_id
 FROM send_calls sc
-LEFT JOIN transfers t ON t.block_number=sc.block_number
+LEFT JOIN transfers t ON t.block_time=sc.block_time
+        AND t.block_number=sc.block_number
         AND t.tx_hash=sc.tx_hash
         AND t.rn=sc.call_send_index
 LEFT JOIN {{ ref('bridges_layerzero_chain_indexes') }} ci ON sc.withdrawal_chain_id=ci.id