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

update

Browse Source
This commit is contained in:
Newnius 2020-07-01 16:59:39 +08:00
parent 4971c41991
commit d4593a7d38
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/optimizer.go
View File

@ -34,7 +34,7 @@ func (optimizer *Optimizer) Init(conf Configuration) {
} }
func (optimizer *Optimizer) FeedTime(job Job, stats [][]TaskStatus) { func (optimizer *Optimizer) FeedTime(job Job, stats [][]TaskStatus) {
log.Info("optimizer feedTime", job) //log.Info("optimizer feedTime", job)
if len(stats) == 0 || len(job.Tasks) != 1 { if len(stats) == 0 || len(job.Tasks) != 1 {
return return
} }
@ -237,13 +237,13 @@ func (optimizer *Optimizer) PredictTime(job Job) OptimizerJobExecutionTime {
if err == nil && msg.Code == 0 { if err == nil && msg.Code == 0 {
tmp := msg.Labels tmp := msg.Labels
if v, ok := tmp["pre"]; ok { if v, ok := tmp["pre"]; ok {
res.Pre = int(math.Ceil(v / 100)) res.Pre = int(math.Ceil(v))
} }
if v, ok := tmp["post"]; ok { if v, ok := tmp["post"]; ok {
res.Post = int(math.Ceil(v/1024)) * 1024 res.Post = int(math.Ceil(v))
} }
if v, ok := tmp["total"]; ok { if v, ok := tmp["total"]; ok {
res.Total = int(math.Ceil(v)/10) * 10 res.Total = int(math.Ceil(v))
} }
} }
return res return res