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) } }