fix(crdb): obtain latest sequences when the tx is retried (#7795)

2025-12-10 05:04:10 +00:00 · 2024-04-18 16:07:05 +03:00
parent 8054e6753a
commit 579113b6ac
3 changed files with 4 additions and 8 deletions
--- a/internal/eventstore/eventstore_pusher_test.go
+++ b/internal/eventstore/eventstore_pusher_test.go
@@ -390,10 +390,10 @@ func TestCRDB_Push_Parallel(t *testing.T) {
 				},
 			},
 			res: res{
-				minErrCount: 1,
+				minErrCount: 0,
 				eventsRes: eventsRes{
 					aggIDs:            []string{"204"},
-					pushedEventsCount: 6,
+					pushedEventsCount: 8,
 					aggTypes:          database.TextArray[eventstore.AggregateType]{eventstore.AggregateType(t.Name())},
 				},
 			},