From dade0ab56e44f1ea6a912aaf9935c62dffbee6f4 Mon Sep 17 00:00:00 2001 From: Newnius Date: Tue, 30 Jun 2020 23:25:38 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 1babe32..0726149 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -551,7 +551,8 @@ func (scheduler *SchedulerFair) UpdateQuota() { request.NumberGPU += GPU request.CPU += CPU request.Memory += Memory - if job.Priority == jobs[0].Priority { + /* increase priority at most 10 jobs, to avoid small jobs always goes first in a batch */ + if job.Priority == jobs[0].Priority && i < 10 { scheduler.queues[queue][i].BasePriority += 1.0 } }