diff --git a/models/evm/streamline/core/retry/_missing_receipts.sql b/models/evm/streamline/core/retry/_missing_receipts.sql index aa8c1dc..beecd4e 100644 --- a/models/evm/streamline/core/retry/_missing_receipts.sql +++ b/models/evm/streamline/core/retry/_missing_receipts.sql @@ -2,33 +2,15 @@ materialized = "ephemeral" ) }} -WITH lookback AS ( - - SELECT - block_number - FROM - {{ ref("_evm_block_lookback") }} -) SELECT - DISTINCT t.block_number AS block_number + DISTINCT block_number AS block_number FROM - {{ ref("silver_evm__transactions") }} - t - LEFT JOIN {{ ref("silver_evm__receipts") }} - r USING ( - block_number, - block_hash, - tx_hash - ) + {{ ref("core_evm__fact_transactions") }} WHERE - r.tx_hash IS NULL - AND t.block_number >= ( + tx_succeeded IS NULL + AND block_number > ( SELECT block_number FROM - lookback - ) - AND t.block_timestamp >= DATEADD('hour', -84, SYSDATE()) - AND ( - r._inserted_timestamp >= DATEADD('hour', -84, SYSDATE()) - OR r._inserted_timestamp IS NULL) + {{ ref("_evm_block_lookback") }} + ) \ No newline at end of file