From e631bc028c6d55ceebf44a062d22ebc769604460 Mon Sep 17 00:00:00 2001 From: Austin <93135983+austinFlipside@users.noreply.github.com> Date: Wed, 27 Aug 2025 14:48:43 -0400 Subject: [PATCH] fact_txs (#130) * fact_txs * updates --- macros/decoded_logs_history.sql | 2 +- models/evm/gold/core/core_evm__fact_transactions.sql | 1 - .../decoder/realtime/streamline__decode_logs_realtime.sql | 2 +- 3 files changed, 2 insertions(+), 3 deletions(-) diff --git a/macros/decoded_logs_history.sql b/macros/decoded_logs_history.sql index 9cc2741..9cdc604 100644 --- a/macros/decoded_logs_history.sql +++ b/macros/decoded_logs_history.sql @@ -59,7 +59,7 @@ concat(l.tx_hash::string, '-', l.event_index::string) as _log_id FROM target_blocks b INNER JOIN {{ ref('core_evm__fact_event_logs') }} l using (block_number) - WHERE l.tx_status = 'SUCCESS' and date_trunc('month', l.block_timestamp) = '{{month}}'::timestamp + WHERE l.tx_succeeded and date_trunc('month', l.block_timestamp) = '{{month}}'::timestamp ) SELECT l.block_number, diff --git a/models/evm/gold/core/core_evm__fact_transactions.sql b/models/evm/gold/core/core_evm__fact_transactions.sql index 71d2667..5e28d93 100644 --- a/models/evm/gold/core/core_evm__fact_transactions.sql +++ b/models/evm/gold/core/core_evm__fact_transactions.sql @@ -188,7 +188,6 @@ missing_data AS ( t.max_priority_fee_per_gas, t.y_parity, t.access_list, - t.authorization_list, t.gas_price, utils.udf_hex_to_int( r.receipts_json :gasUsed :: STRING diff --git a/models/evm/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql b/models/evm/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql index 349f513..a414cf2 100644 --- a/models/evm/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql +++ b/models/evm/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql @@ -54,7 +54,7 @@ candidate_logs AS ( INNER JOIN {{ ref('core_evm__fact_event_logs') }} l USING (block_number) WHERE - l.tx_status = 'SUCCESS' + l.tx_succeeded AND l.inserted_timestamp :: DATE >= DATEADD('day', -2, SYSDATE()) ) SELECT