diff --git a/pkg/scheduler/internal/queue/scheduling_queue.go b/pkg/scheduler/internal/queue/scheduling_queue.go index 40f4fc02786..e7beed5a398 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue.go +++ b/pkg/scheduler/internal/queue/scheduling_queue.go @@ -48,8 +48,8 @@ import ( ) const ( - // If the pod stays in unschedulableQ longer than the unschedulableQTimeInterval, - // the pod will be moved from unschedulableQ to activeQ. + // If a pod stays in unschedulableQ longer than unschedulableQTimeInterval, + // the pod will be moved from unschedulableQ to backoffQ or activeQ. unschedulableQTimeInterval = 60 * time.Second queueClosed = "scheduling queue is closed" @@ -434,8 +434,8 @@ func (p *PriorityQueue) flushBackoffQCompleted() { } } -// flushUnschedulableQLeftover moves pod which stays in unschedulableQ longer than the unschedulableQTimeInterval -// to activeQ. +// flushUnschedulableQLeftover moves pods which stay in unschedulableQ longer than unschedulableQTimeInterval +// to backoffQ or activeQ. func (p *PriorityQueue) flushUnschedulableQLeftover() { p.lock.Lock() defer p.lock.Unlock()