From 9437159a3e030926e4c729549525fc980634339e Mon Sep 17 00:00:00 2001 From: RamezesDong Date: Sun, 5 Nov 2023 17:02:14 +0800 Subject: [PATCH] fix: reclaim pop queue error Signed-off-by: RamezesDong --- pkg/scheduler/actions/reclaim/reclaim.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/scheduler/actions/reclaim/reclaim.go b/pkg/scheduler/actions/reclaim/reclaim.go index 430ec99a98..d4cdbd6fc0 100644 --- a/pkg/scheduler/actions/reclaim/reclaim.go +++ b/pkg/scheduler/actions/reclaim/reclaim.go @@ -104,6 +104,7 @@ func (ra *Action) Execute(ssn *framework.Session) { job = jobs.Pop().(*api.JobInfo) } + queues.Push(queue) // Found "high" priority task to reclaim others if tasks, found := preemptorTasks[job.UID]; !found || tasks.Empty() { continue @@ -212,7 +213,6 @@ func (ra *Action) Execute(ssn *framework.Session) { if assigned { jobs.Push(job) } - queues.Push(queue) } }