crosschain-models/models/silver/observability/silver__data_delay.sql

{{ config(
    materialized = 'incremental',
    merge_exclude_columns = ["inserted_timestamp"],
    unique_key = ['blockchain','test_timestamp'],
    full_refresh = false,
    tags = ['observability']
) }}

WITH base AS (

    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'arbitrum' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'arbitrum_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'bsc' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'bsc_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'ethereum' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'ethereum_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'polygon' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'polygon_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'base' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'base_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'gnosis' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'gnosis_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'avalanche' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'avalanche_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'optimism' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'optimism_silver',
            'traces'
        ) }}
    UNION
    SELECT
        MAX(block_timestamp) AS max_timestamp,
        'blast' AS chain,
        DATEDIFF(
            'minutes',
            max_timestamp,
            CURRENT_TIMESTAMP
        ) AS delay
    FROM
        {{ source(
            'blast_silver',
            'traces'
        ) }}
)
SELECT
    max_timestamp,
    chain AS blockchain,
    delay,
    'traces' AS test_table,
    CURRENT_TIMESTAMP AS test_timestamp,
    sysdate() as inserted_timestamp,
    sysdate() as modified_timestamp,
    {{ dbt_utils.generate_surrogate_key(['blockchain','test_timestamp']) }} AS data_delay_id,
    '{{ invocation_id }}' as _invocation_id
FROM
    base