logic fix

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) %}

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) %}