-record(process_events, {
    aggregate_id :: binary(),
    events :: list(eventsourcing:event_envelop(any()))
}).