github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 22:46:12 +00:00
Code Issues Projects Releases Wiki Activity

cleanup: remove non-necessary ifs

Browse Source
This commit is contained in:
Kensei Nakada 2024-07-06 13:19:24 +00:00
parent 8d0ee91fc7
commit 41f7607c04
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/scheduler/internal/queue/scheduling_queue.go
View File

@ -681,16 +681,8 @@ func (p *PriorityQueue) determineSchedulingHintForInFlightPod(logger klog.Logger
// we can assume pInfo must be recorded in inFlightPods and thus inFlightEvents. // we can assume pInfo must be recorded in inFlightPods and thus inFlightEvents.
inFlightPod, ok := p.inFlightPods[pInfo.Pod.UID] inFlightPod, ok := p.inFlightPods[pInfo.Pod.UID]
if !ok { if !ok {
// This can happen while updating a pod. In that case pInfo.UnschedulablePlugins should logger.Error(nil, "In flight Pod isn't found in the scheduling queue. If you see this error log, it's likely a bug in the scheduler.", "pod", klog.KObj(pInfo.Pod))
// be empty. If it is not, we may have a problem. return queueAfterBackoff
if len(pInfo.UnschedulablePlugins) != 0 {
logger.Error(nil, "In flight Pod isn't found in the scheduling queue. If you see this error log, it's likely a bug in the scheduler.", "pod", klog.KObj(pInfo.Pod))
return queueAfterBackoff
}
if p.inFlightEvents.Len() > len(p.inFlightPods) {
return queueAfterBackoff
}
return queueSkip
} }
rejectorPlugins := pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins) rejectorPlugins := pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins)