-record(runtime, {
    pipeline :: lightspeed@pipeline:pipeline(),
    lifecycle :: lightspeed@pipeline:lifecycle(),
    next_run_seq :: integer(),
    checkpoints_rev :: list(lightspeed@pipeline@checkpoint:checkpoint()),
    sink_idempotency_keys_rev :: list(binary()),
    telemetry :: lightspeed@pipeline@telemetry:snapshot()
}).