diff --git a/models/streamline/core/complete/streamline__block_txs_complete.sql b/models/streamline/core/complete/streamline__block_txs_complete.sql
index c2b459c..7713330 100644
--- a/models/streamline/core/complete/streamline__block_txs_complete.sql
+++ b/models/streamline/core/complete/streamline__block_txs_complete.sql
@@ -26,6 +26,15 @@ WHERE
         FROM
             {{ this }}
     )
+    AND partition_key > (
+        SELECT
+            COALESCE(
+                MAX(partition_key),
+                0
+            )
+        FROM
+            {{ this }}
+    )
 {% else %}
     {{ ref('bronze__FR_transactions') }}
 {% endif %}