Don't forget rate limiting state on error

Azure · Nov 6, 2023 · a20ecdc · a20ecdc
1 parent d1c5067
commit a20ecdc
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/internal/reconstitution/writebuffer.go b/internal/reconstitution/writebuffer.go
@@ -102,7 +102,6 @@ func (w *writeBuffer) processQueueItem(ctx context.Context) bool {
 	w.mut.Lock()
 	w.state[sliceNSN] = append(w.state[sliceNSN], updates...)
 	w.mut.Unlock()
-	w.queue.Forget(item)
 	w.queue.AddRateLimited(item)
 
 	return true