From cfad24d26cfa27d77c81297364eac80830aca1a2 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Thu, 1 Aug 2019 14:13:14 +0800
Subject: [PATCH] update shceduler_fair, bugfix

---
 src/scheduler_fair.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go
index 1c401b7..e27c86c 100644
--- a/src/scheduler_fair.go
+++ b/src/scheduler_fair.go
@@ -96,7 +96,6 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
 				scheduler.history[i].Status = Finished
 			}
 		}
-		scheduler.UpdateNextQueue()
 		break
 	case Stopped:
 		for i := range scheduler.history {
@@ -104,7 +103,6 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
 				scheduler.history[i].Status = Stopped
 			}
 		}
-		scheduler.UpdateNextQueue()
 		break
 	}
 }
@@ -192,7 +190,9 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus {
 			cnt.MemoryGPU += v.MemoryTotal
 		}
 		log.Info(job.Group, cnt)
-		scheduler.UpdateNextQueue()
+		if len(res.Status) != 0 {
+			scheduler.UpdateNextQueue()
+		}
 	}(res)
 	return res
 }