-record(checkpoint, {
    run_id :: binary(),
    stage :: binary(),
    sequence :: integer(),
    watermark :: lightspeed@pipeline@checkpoint:watermark(),
    idempotency_key :: binary(),
    at_ms :: integer()
}).