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`.