default__snapshot_staging_table.sql

...
insertions as (
    select
        'insert' as dbt_change_type,
        source_data.*,
        {#- additional operational metadata fields #}
        cast("{{ invocation_id }}" as STRING) as INSERT_PROCESS_ID,
        cast(NULL as STRING) as UPDATE_PROCESS_ID,
        {{ strategy.updated_at }} as EFFECTIVE_START_TIMESTAMP,
        cast("{{ var('default_high_dttm') }}" as TIMESTAMP) as EFFECTIVE_END_TIMESTAMP,
        {{ strategy.updated_at }} as INSERT_TIMESTAMP,
        cast(NULL as TIMESTAMP) as UPDATE_TIMESTAMP
    from insertions_source_data as source_data
    left outer join snapshotted_data on snapshotted_data.dbt_unique_key = source_data.dbt_unique_key
    where snapshotted_data.dbt_unique_key is null
        or (
            snapshotted_data.dbt_unique_key is not null
        and (
            {{ strategy.row_changed }}
        )
    )
),
updates as (
    select
        'update' as dbt_change_type,
        source_data.*,
        snapshotted_data.dbt_scd_id,
        {#- additional operational metadata fields #}
        snapshotted_data.INSERT_PROCESS_ID,
        cast("{{ invocation_id }}" as STRING) as UPDATE_PROCESS_ID,
        snapshotted_data.EFFECTIVE_START_TIMESTAMP,
        {{ strategy.updated_at }} as EFFECTIVE_END_TIMESTAMP,
        snapshotted_data.INSERT_TIMESTAMP,
        {{ strategy.updated_at }} UPDATE_TIMESTAMP
    from updates_source_data as source_data
    join snapshotted_data on snapshotted_data.dbt_unique_key = source_data.dbt_unique_key
    where (
        {{ strategy.row_changed }}
    )
)
...