-record(lineage_record, {
    run_id :: binary(),
    stage :: binary(),
    source_signature :: binary(),
    sink_signature :: binary(),
    watermark_signature :: binary(),
    sequence :: integer(),
    checkpoint_signature :: binary()
}).