Fix concurrency query

hirethunk · Nov 17, 2023 · b59ade7 · b59ade7
1 parent 0e3aa2e
commit b59ade7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Lifecycle/EventStore.php b/src/Lifecycle/EventStore.php
@@ -70,7 +70,8 @@ protected function guardAgainstConcurrentWrites(array $events): void
             )),
         ]);
 
-        $query->orderBy('id');
+        $query->groupBy('state_type', 'state_id');
+        $query->orderBy('state_id');
 
         $query->where(function (BaseBuilder $query) use ($events, $max_event_ids) {
             foreach ($events as $event) {