Event Sourcing - repository

repository.py

class MyRepository:
    def get(self, id_) -> MyAggregate:
        """Replay an aggregate from the event log."""
        ...

    def persist(self, aggregate: MyAggregate) -> None:
        self._insert_new_events(aggregate.pop_pending_events())