From d4ea78ea395425a4340ff3458262c9b68fc45f4f Mon Sep 17 00:00:00 2001 From: danielqsj Date: Tue, 2 Jul 2019 11:08:48 +0800 Subject: [PATCH] call unreserve plugin before record event --- pkg/scheduler/scheduler.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index 8aa67512497..826ab3db76f 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -552,9 +552,9 @@ func (sched *Scheduler) scheduleOne() { if forgetErr := sched.Cache().ForgetPod(assumedPod); forgetErr != nil { klog.Errorf("scheduler cache ForgetPod failed: %v", forgetErr) } - sched.recordSchedulingFailure(assumedPod, permitStatus.AsError(), reason, permitStatus.Message()) // trigger un-reserve plugins to clean up state associated with the reserved Pod fwk.RunUnreservePlugins(pluginContext, assumedPod, scheduleResult.SuggestedHost) + sched.recordSchedulingFailure(assumedPod, permitStatus.AsError(), reason, permitStatus.Message()) return } @@ -571,9 +571,9 @@ func (sched *Scheduler) scheduleOne() { if forgetErr := sched.Cache().ForgetPod(assumedPod); forgetErr != nil { klog.Errorf("scheduler cache ForgetPod failed: %v", forgetErr) } - sched.recordSchedulingFailure(assumedPod, prebindStatus.AsError(), reason, prebindStatus.Message()) // trigger un-reserve plugins to clean up state associated with the reserved Pod fwk.RunUnreservePlugins(pluginContext, assumedPod, scheduleResult.SuggestedHost) + sched.recordSchedulingFailure(assumedPod, prebindStatus.AsError(), reason, prebindStatus.Message()) return }