We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ac24cbc commit 944ef63Copy full SHA for 944ef63
pkg/controller/priorityqueue/priorityqueue.go
@@ -239,6 +239,7 @@ func (w *priorityqueue[T]) spin() {
239
}
240
241
for {
242
+ metricsAscend := false
243
pivotChange := false
244
245
w.queue.AscendGreaterOrEqual(&pivot, func(item *item[T]) bool {
@@ -264,7 +265,8 @@ func (w *priorityqueue[T]) spin() {
264
265
266
267
- if w.waiters.Load() == 0 {
268
+ if w.waiters.Load() == 0 || metricsAscend {
269
+ metricsAscend = true
270
// Have to keep iterating here to ensure we update metrics
271
// for further items that became ready and set nextReady.
272
return true
0 commit comments