diff --git a/macros/tests/missing_decoding.sql b/macros/tests/missing_decoding.sql new file mode 100644 index 0000000..7ccb72a --- /dev/null +++ b/macros/tests/missing_decoding.sql @@ -0,0 +1,17 @@ +{% test missing_decoded_logs(model) %} +SELECT + l.block_number, + l._log_id +FROM + {{ ref('silver__logs') }} + l + LEFT JOIN {{ model }} + d + ON l.block_number = d.block_number + AND l._log_id = d._log_id +WHERE + l.contract_address = LOWER('0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c') -- WBNB + AND l.topics [0] :: STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef' -- Transfer + AND l.block_timestamp BETWEEN DATEADD('hour', -48, SYSDATE()) + AND DATEADD('hour', -6, SYSDATE()) + AND d._log_id IS NULL {% endtest %} diff --git a/models/silver/core/silver__decoded_logs.sql b/models/silver/core/silver__decoded_logs.sql index 6c5322a..6fc7bdb 100644 --- a/models/silver/core/silver__decoded_logs.sql +++ b/models/silver/core/silver__decoded_logs.sql @@ -36,7 +36,7 @@ WITH base_data AS ( WHERE TO_TIMESTAMP_NTZ(_inserted_timestamp) >= ( SELECT - MAX(_inserted_timestamp) + MAX(_inserted_timestamp) - INTERVAL '4 hours' FROM {{ this }} ) diff --git a/models/silver/core/tests/decoded_logs/test_silver__decoded_logs_recent.yml b/models/silver/core/tests/decoded_logs/test_silver__decoded_logs_recent.yml index a72e60b..f92501e 100644 --- a/models/silver/core/tests/decoded_logs/test_silver__decoded_logs_recent.yml +++ b/models/silver/core/tests/decoded_logs/test_silver__decoded_logs_recent.yml @@ -9,6 +9,7 @@ models: datepart: day field: _INSERTED_TIMESTAMP interval: 1 + - missing_decoded_logs columns: - name: BLOCK_NUMBER