Merge pull request #27 from christopherzli/test_chris_6

exclude 409 errors
databricks · Apr 4, 2024 · 7175992 · 7175992
2 parents 514eaf0 + 64f2964
commit 7175992
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go
@@ -798,6 +798,9 @@ func (h *Handler) fanoutForward(pctx context.Context, tenant string, wreqs map[e
 					Replica: int64(writeTarget.replica + 1),
 				})
 			})
+			if isConflict(err) {
+				err = nil
+			}
 			if err != nil {
 				// Check if peer connection is unavailable, don't attempt to send requests constantly.
 				if st, ok := status.FromError(err); ok {