From 2a85727ec5da6f9f165241a804fb8d81579c4a32 Mon Sep 17 00:00:00 2001 From: Jun Gong Date: Mon, 28 Oct 2019 14:59:42 +0800 Subject: [PATCH] When schedule begins, run snapshot before prefilter plugins --- pkg/scheduler/core/generic_scheduler.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/pkg/scheduler/core/generic_scheduler.go b/pkg/scheduler/core/generic_scheduler.go index 945a5f17221..afa83f29267 100644 --- a/pkg/scheduler/core/generic_scheduler.go +++ b/pkg/scheduler/core/generic_scheduler.go @@ -183,13 +183,6 @@ func (g *genericScheduler) Schedule(ctx context.Context, state *framework.CycleS } trace.Step("Basic checks done") - // Run "prefilter" plugins. - preFilterStatus := g.framework.RunPreFilterPlugins(ctx, state, pod) - if !preFilterStatus.IsSuccess() { - return result, preFilterStatus.AsError() - } - trace.Step("Running prefilter plugins done") - if err := g.snapshot(); err != nil { return result, err } @@ -199,6 +192,13 @@ func (g *genericScheduler) Schedule(ctx context.Context, state *framework.CycleS return result, ErrNoNodesAvailable } + // Run "prefilter" plugins. + preFilterStatus := g.framework.RunPreFilterPlugins(ctx, state, pod) + if !preFilterStatus.IsSuccess() { + return result, preFilterStatus.AsError() + } + trace.Step("Running prefilter plugins done") + startPredicateEvalTime := time.Now() filteredNodes, failedPredicateMap, filteredNodesStatuses, err := g.findNodesThatFit(ctx, state, pod) if err != nil {