pluto
pluto copied to clipboard
Integrate replaying upon recovery
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.