solana-models/models/streamline/streamline__all_unknown_block_txs_historical.sql

{{ config(
    materialized = 'view',
    tags = ['streamline'],
) }}

WITH pre_final AS (

    SELECT
        SEQ8()+98680445 AS block_id
    FROM
        TABLE(GENERATOR(rowcount => 60000000))
    WHERE
        block_id > 98680445
        AND block_id <= 148693779
    EXCEPT
    SELECT
        block_id
    FROM
        {{ ref('streamline__complete_block_txs') }}
)
SELECT
    block_id,
    (
        SELECT
            coalesce(MAX(_partition_id) + 1,1)
        FROM
            {{ ref('streamline__complete_block_txs') }}
    ) AS batch_id
FROM
    pre_final