analytics_events_quarantine_to_final.pipe

NODE copy_quarantine
SQL >
    SELECT
        toDateTime(
            fromUnixTimestamp64Milli(toUInt64(assumeNotNull(timestamp)) * 1000)
        ) timestamp,
        assumeNotNull(session_id) session_id,
        assumeNotNull(action) action,
        assumeNotNull(version) version,
        assumeNotNull(payload) payload
    FROM analytics_events_quarantine

TYPE COPY
TARGET_DATASOURCE analytics_events