When a group is recovered, events must be replayed before the execution DAGs start receiving new events. Therefore the current implementation of the query `create` method must be separated into `setup/replay` and `start`.
When a group is recovered, events must be replayed before the execution DAGs start receiving new events.
Therefore the current implementation of the query
createmethod must be separated intosetup/replayandstart.