diff --git a/models/streamline/core/realtime/streamline__block_txs_2.sql b/models/streamline/core/realtime/streamline__block_txs_2.sql index eb5c4fa1..e3d0e525 100644 --- a/models/streamline/core/realtime/streamline__block_txs_2.sql +++ b/models/streamline/core/realtime/streamline__block_txs_2.sql @@ -19,7 +19,7 @@ {% set next_batch_num_query %} SELECT greatest( - 129041, /* cutoff partition id in PROD after deploy */ + 150000, /* This partition id needs to start at a value greater than the current max partition of the legacy streamline data */ (SELECT coalesce(max(_partition_id),0) FROM {{ ref('streamline__complete_block_txs_2') }}) )+1 {% endset %}