YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 22:31:55 +00:00
Code Issues Releases Wiki Activity

update preempt

Browse Source
This commit is contained in:
Newnius 2020-06-03 20:43:42 +08:00
parent 33041d3a45
commit 02ae5a4483
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/scheduler_priority.go
View File

@ -93,9 +93,9 @@ func (scheduler *SchedulerPriority) Start() {
for _, task := range jobT.Tasks { for _, task := range jobT.Tasks {
numberGPUt += task.NumberGPU numberGPUt += task.NumberGPU
} }
log.Info(time.Now().UnixNano())
needGPU := InstanceOfResourcePool().TotalGPU - InstanceOfResourcePool().UsingGPU needGPU := InstanceOfResourcePool().TotalGPU - InstanceOfResourcePool().UsingGPU
score = float64(jobT.CreatedAt) * math.Abs(float64(numberGPU-numberGPUt+needGPU)) / float64(numberGPUt) score = float64(time.Now().UnixNano()/100000-int64(jobT.CreatedAt)) * math.Abs(float64(numberGPU-numberGPUt+needGPU)) / float64(numberGPUt)
if score < minScore { if score < minScore {
minScore = score minScore = score