From eafcf167fa26aa14aa12744c2545f8c2f58052b4 Mon Sep 17 00:00:00 2001 From: jacksan Date: Thu, 3 Apr 2025 15:20:34 -0600 Subject: [PATCH] logic fix --- .../streamline/core/realtime/streamline__chunks_realtime.sql | 3 ++- .../core/realtime/streamline__transactions_realtime.sql | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/models/streamline/core/realtime/streamline__chunks_realtime.sql b/models/streamline/core/realtime/streamline__chunks_realtime.sql index 8778185..3ca2da3 100644 --- a/models/streamline/core/realtime/streamline__chunks_realtime.sql +++ b/models/streamline/core/realtime/streamline__chunks_realtime.sql @@ -32,7 +32,8 @@ tbl AS ( LEFT JOIN {{ ref('streamline__chunks') }} A ON A.block_id = C.block_id LEFT JOIN {{ ref('streamline__chunks_complete') }} B ON A.chunk_hash = B.chunk_hash WHERE - B.chunk_hash IS NULL + A.chunk_hash IS NOT NULL + AND B.chunk_hash IS NULL ) {% else %} {% if var('STREAMLINE_BACKFILL', false) %} diff --git a/models/streamline/core/realtime/streamline__transactions_realtime.sql b/models/streamline/core/realtime/streamline__transactions_realtime.sql index 0fd5d88..783e4ad 100644 --- a/models/streamline/core/realtime/streamline__transactions_realtime.sql +++ b/models/streamline/core/realtime/streamline__transactions_realtime.sql @@ -37,8 +37,8 @@ tbl AS ( LEFT JOIN {{ ref('streamline__transactions') }} A ON A.block_id = C.block_id LEFT JOIN {{ ref('streamline__transactions_complete') }} B ON A.tx_hash = B.tx_hash WHERE - B.tx_hash IS NULL - AND A.signer_id IS NOT NULL + A.tx_hash IS NOT NULL + AND B.tx_hash IS NULL ) {% else %} {% if var('STREAMLINE_BACKFILL', false) %}