rework write aggregate concurrency