Event Sourcing - repository
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()) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment