add debug

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
 		}

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