github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-13 13:14:05 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #125930 from sanposhiho/cleanup-ifs

Browse Source 
cleanup: remove non-necessary `if`s
This commit is contained in:
Kubernetes Prow Robot
2024-07-08 14:13:50 -07:00
committed by GitHub
parent b106c291c3 41f7607c04
commit 7cf5ae8e98
1 changed files with 2 additions and 10 deletions
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.
inFlightPod, ok := p.inFlightPods[pInfo.Pod.UID]
if !ok {
// This can happen while updating a pod. In that case pInfo.UnschedulablePlugins should
// be empty. If it is not, we may have a problem.
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
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
}
rejectorPlugins := pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins)