feat: verify durable arrival conflicts, reopen bounded Kafka subscriptions with retired clients, refresh deduplicated transport evidence and alert on sanitized sync backlogs with rollout docs and CI regressions

Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
This commit is contained in:
Matthew Meszaros
2026-10-09 13:19:32 +00:00
co-authored by Devin AI
parent 6ce1a2aebb
commit e3769ef666
22 changed files with 399 additions and 27 deletions
+7 -1
View File
@@ -205,7 +205,13 @@ jobs:
go test -race ./internal/repository -run '^TestLive(LastWarmupSendFailure|PersistentMailboxLoadingFailure|DispatchRetry|LineageQueueRevisions|WarmupRecoversOldPreparation|WarmupPreparationRecoveryRetains)' -count=1
go test -race ./internal/tasks -run '^Test(LiveWarmup(SafetyHoldReschedules|Recovery|TaskDoesNotApplyResults)|WarmupSenderDistinguishes)' -count=1
- name: Test the Kafka codec and client lifecycle
- name: Mailbox sync admission, replay, truthful state and upgrade regressions (PostgreSQL)
env:
WARMBLY_TEST_DB: postgres://warmbly:warmbly@127.0.0.1:5432/warmbly_test?sslmode=disable
run: |
go test -race -p 1 ./internal/repository ./internal/app/consumer ./internal/app/orgtransfer ./internal/infrastructure/db -run '^TestLive(SyncArrival|SyncTruth|EmailErrorDedupe)' -count=1
- name: Test the Kafka codec, failed-handler replay and client lifecycle
run: go test -race -tags kafka ./internal/infrastructure/codec/ ./internal/infrastructure/kafka/ ./internal/infrastructure/eventbus/
# fail_ci_if_error does not cover the uploader crashing before it runs