How fix instructions preserved normal synchronization
Simplified Fix Instruction
AI Agent implemented fix w/ Fix Instruction
sync/queue.goAnonymized illustrative patch42func sendPendingUpdates(ctx context.Context, peer Peer, cursor Cursor) error {43 queue := peer.OutboundQueue()44 queueSize := queue.Size()45 queueCapacity := queue.Capacity()4647+ if queueSize >= queueCapacity {48+ return retryScheduler.Defer(peer.ID(), retryDelay)49+ }5051 update, err := loadNextPendingUpdate(ctx, cursor)52 if err != nil {53 return fmt.Errorf("load pending update: %w", err)54 }5556 return queue.Enqueue(ctx, update)57}