include/lightspeed@pipeline@orchestrator_RetryRecord.hrl

-record(retry_record, {
    batch_key :: binary(),
    next_attempt :: integer(),
    reason :: binary(),
    retry_at_ms :: integer()
}).