add partition_key filter

2026-02-06 15:47:11 +00:00 · 2025-01-07 09:30:36 -08:00 · 2025-01-07 09:30:36 -08:00 · 28659259c0
commit 28659259c0
parent 0dd027391c
1 changed files with 9 additions and 0 deletions
--- 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 %}