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