From 859cac059596f9dda1cb2de93d8d487578f61e1b Mon Sep 17 00:00:00 2001 From: draveness Date: Wed, 31 Jul 2019 15:27:03 +0800 Subject: [PATCH] fix: update run filter plugin for consistency --- pkg/scheduler/framework/v1alpha1/framework.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/pkg/scheduler/framework/v1alpha1/framework.go b/pkg/scheduler/framework/v1alpha1/framework.go index 4ba141f64bd..10606950c20 100644 --- a/pkg/scheduler/framework/v1alpha1/framework.go +++ b/pkg/scheduler/framework/v1alpha1/framework.go @@ -312,13 +312,12 @@ func (f *framework) RunPrefilterPlugins( // Meanwhile, the failure message and status are set for the given node. func (f *framework) RunFilterPlugins(pc *PluginContext, pod *v1.Pod, nodeName string) *Status { - - for _, p := range f.filterPlugins { - status := p.Filter(pc, pod, nodeName) + for _, pl := range f.filterPlugins { + status := pl.Filter(pc, pod, nodeName) if !status.IsSuccess() { if status.Code() != Unschedulable { - errMsg := fmt.Sprintf("RunFilterPlugins: error while running %s filter plugin for pod %s: %s", - p.Name(), pod.Name, status.Message()) + errMsg := fmt.Sprintf("RunFilterPlugins: error while running %v filter plugin for pod %v: %v", + pl.Name(), pod.Name, status.Message()) klog.Error(errMsg) return NewStatus(Error, errMsg) }