From 92ba2a4e09bb79209ed44e2ce1d256cb854b66e1 Mon Sep 17 00:00:00 2001 From: Wei Huang Date: Fri, 24 Apr 2020 12:12:11 -0700 Subject: [PATCH] Simplify status handling of scheduler RunFilterPlugins --- pkg/scheduler/framework/v1alpha1/framework.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/pkg/scheduler/framework/v1alpha1/framework.go b/pkg/scheduler/framework/v1alpha1/framework.go index 34becd40c72..c806e8636d2 100644 --- a/pkg/scheduler/framework/v1alpha1/framework.go +++ b/pkg/scheduler/framework/v1alpha1/framework.go @@ -424,19 +424,15 @@ func (f *framework) RunFilterPlugins( pod *v1.Pod, nodeInfo *NodeInfo, ) PluginToStatus { - var firstFailedStatus *Status statuses := make(PluginToStatus) for _, pl := range f.filterPlugins { pluginStatus := f.runFilterPlugin(ctx, pl, state, pod, nodeInfo) - if len(statuses) == 0 { - firstFailedStatus = pluginStatus - } if !pluginStatus.IsSuccess() { if !pluginStatus.IsUnschedulable() { // Filter plugins are not supposed to return any status other than // Success or Unschedulable. - firstFailedStatus = NewStatus(Error, fmt.Sprintf("running %q filter plugin for pod %q: %v", pl.Name(), pod.Name, pluginStatus.Message())) - return map[string]*Status{pl.Name(): firstFailedStatus} + errStatus := NewStatus(Error, fmt.Sprintf("running %q filter plugin for pod %q: %v", pl.Name(), pod.Name, pluginStatus.Message())) + return map[string]*Status{pl.Name(): errStatus} } statuses[pl.Name()] = pluginStatus if !f.runAllFilters {