When schedule begins, run snapshot before prefilter plugins

This commit is contained in:
Jun Gong 2019-10-28 14:59:42 +08:00
parent 7d13dfe3c3
commit 2a85727ec5

View File

@ -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 {