add message state on conflict error

shorsher · shorsher · commit e4a24f31cbcb · 2024-11-01T15:23:34.000-04:00
diff --git a/internal/batch/batch_processor.go b/internal/batch/batch_processor.go
@@ -636,6 +636,7 @@ func (bp *batchProcessor) dispatchBatch(payload *DispatchPayload) error {
 				conflictErr, conflictTestOk := err.(operations.ConflictError)
 				if conflictTestOk && conflictErr.IsConflictError() {
 					// We know that the connector has received our batch, so we shouldn't need to retry
+					payload.addMessageUpdate(payload.Messages, core.MessageStateReady, core.MessageStateSent)
 					return true, nil
 				}
 			} else {

Original file line number	Diff line number	Diff line change
`@@ -636,6 +636,7 @@ func (bp batchProcessor) dispatchBatch(payload DispatchPayload) error {`
`636`	`636`	`conflictErr, conflictTestOk := err.(operations.ConflictError)`
`637`	`637`	`if conflictTestOk && conflictErr.IsConflictError() {`
`638`	`638`	`// We know that the connector has received our batch, so we shouldn't need to retry`
	`639`	`+ payload.addMessageUpdate(payload.Messages, core.MessageStateReady, core.MessageStateSent)`
`639`	`640`	`return true, nil`
`640`	`641`	`}`
`641`	`642`	`} else {`