From 05222105db9ed28540caedfd335fa85d4abadd2a Mon Sep 17 00:00:00 2001 From: Austin <93135983+austinFlipside@users.noreply.github.com> Date: Wed, 24 May 2023 11:17:34 -0400 Subject: [PATCH] add missing txs tests (#561) --- macros/tests/tx_gaps.sql | 36 ++++++++++++++++++- tests/ethereum/test_silver__missing_txs.sql | 2 ++ .../test_silver__recent_missing_txs.sql | 2 ++ 3 files changed, 39 insertions(+), 1 deletion(-) create mode 100644 tests/ethereum/test_silver__missing_txs.sql create mode 100644 tests/ethereum/test_silver__recent_missing_txs.sql diff --git a/macros/tests/tx_gaps.sql b/macros/tests/tx_gaps.sql index a9d93df8..bb727a1e 100644 --- a/macros/tests/tx_gaps.sql +++ b/macros/tests/tx_gaps.sql @@ -6,7 +6,41 @@ block_number, tx_count FROM - {{ ref('silver__blocks') }} + {{ ref('test_silver__blocks_full') }} + ), + model_name AS ( + SELECT + block_number, + COUNT( + DISTINCT tx_hash + ) AS model_tx_count + FROM + {{ model }} + GROUP BY + block_number + ) +SELECT + block_base.block_number, + tx_count, + model_name.block_number AS model_block_number, + model_tx_count +FROM + block_base + LEFT JOIN model_name + ON block_base.block_number = model_name.block_number +WHERE + tx_count <> model_tx_count +{% endmacro %} + +{% macro recent_tx_gaps( + model + ) %} + WITH block_base AS ( + SELECT + block_number, + tx_count + FROM + {{ ref('test_silver__blocks_recent') }} ), model_name AS ( SELECT diff --git a/tests/ethereum/test_silver__missing_txs.sql b/tests/ethereum/test_silver__missing_txs.sql new file mode 100644 index 00000000..499466f2 --- /dev/null +++ b/tests/ethereum/test_silver__missing_txs.sql @@ -0,0 +1,2 @@ +-- depends_on: {{ ref('test_silver__blocks_full') }} +{{ tx_gaps(ref("test_silver__transactions_full")) }} diff --git a/tests/ethereum/test_silver__recent_missing_txs.sql b/tests/ethereum/test_silver__recent_missing_txs.sql new file mode 100644 index 00000000..3d02c92b --- /dev/null +++ b/tests/ethereum/test_silver__recent_missing_txs.sql @@ -0,0 +1,2 @@ +-- depends_on: {{ ref('test_silver__blocks_recent') }} +{{ recent_tx_gaps(ref("test_silver__transactions_recent")) }}