From 272b2b3f5c35a226981be677f14e60e0dee82d2b Mon Sep 17 00:00:00 2001 From: Austin Date: Wed, 11 Oct 2023 10:18:14 -0400 Subject: [PATCH] temp table --- .../core/silver__replay_trace_blocks.sql | 46 +++++++++++++++++++ models/silver/core/silver__traces2.sql | 2 +- 2 files changed, 47 insertions(+), 1 deletion(-) create mode 100644 models/silver/core/silver__replay_trace_blocks.sql diff --git a/models/silver/core/silver__replay_trace_blocks.sql b/models/silver/core/silver__replay_trace_blocks.sql new file mode 100644 index 0000000..55afde0 --- /dev/null +++ b/models/silver/core/silver__replay_trace_blocks.sql @@ -0,0 +1,46 @@ +{{ config( + materialized = 'table' +) }} + +WITH txs_base AS ( + + SELECT + block_number AS base_block_number, + tx_hash AS base_tx_hash + FROM + {{ ref('silver__transactions') }} +), +model_name AS ( + SELECT + block_number AS model_block_number, + tx_hash AS model_tx_hash + FROM + {{ ref('silver__traces2') }} +), +FINAL AS ( + SELECT + base_block_number, + base_tx_hash, + model_block_number, + model_tx_hash + FROM + txs_base + LEFT JOIN model_name + ON base_block_number = model_block_number + AND base_tx_hash = model_tx_hash + WHERE + ( + model_tx_hash IS NULL + OR model_block_number IS NULL + ) + AND base_block_number <= ( + SELECT + MAX(model_block_number) + FROM + model_name + ) +) +SELECT + DISTINCT base_block_number AS missing_block +FROM + FINAL diff --git a/models/silver/core/silver__traces2.sql b/models/silver/core/silver__traces2.sql index bc43f3e..5ca914f 100644 --- a/models/silver/core/silver__traces2.sql +++ b/models/silver/core/silver__traces2.sql @@ -22,7 +22,7 @@ WITH bronze_traces AS ( SELECT DISTINCT missing_block FROM - silver.replay_trace_blocks + {{ ref('silver__replay_trace_blocks') }} ) AND DATA :result IS NOT NULL qualify(ROW_NUMBER() over (PARTITION BY block_number, tx_position ORDER BY