From 005a7400b2da7bbf96c703ed7d75a97da343f753 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Thu, 24 Oct 2019 13:31:03 +0800
Subject: [PATCH] add debug

---
 src/job_manager.go    | 1 +
 src/scheduler_fair.go | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/src/job_manager.go b/src/job_manager.go
index fb81aec..a1f0051 100644
--- a/src/job_manager.go
+++ b/src/job_manager.go
@@ -169,6 +169,7 @@ func (jm *JobManager) status() MsgJobStatus {
 
 		var res MsgTaskStatus
 		err = json.Unmarshal([]byte(string(body)), &res)
+		log.Info(res)
 		if err != nil {
 			continue
 		}
diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go
index a154e28..31fb0d9 100644
--- a/src/scheduler_fair.go
+++ b/src/scheduler_fair.go
@@ -353,6 +353,11 @@ func (scheduler *SchedulerFair) UpdateNextQueue() {
 		tmp += float64(v.NumberGPU) / NumberGPU
 		tmp += float64(v.MemoryGPU) / MemoryGPU
 		tmp /= 4
+		weight := 10
+		if g, ok2 := InstanceOfGroupManager().groups[k]; !ok2 {
+			weight = g.Weight
+		}
+		tmp /= float64(weight)
 		if tmp < quota {
 			quota = tmp
 			next = k