mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-12-15 08:16:43 +00:00
update
This commit is contained in:
@@ -65,6 +65,9 @@ func (jm *JobManager) start() {
|
|||||||
i = -1
|
i = -1
|
||||||
start = time.Now().Unix()
|
start = time.Now().Unix()
|
||||||
}
|
}
|
||||||
|
if i == -1 {
|
||||||
|
break
|
||||||
|
}
|
||||||
time.Sleep(time.Second * 1)
|
time.Sleep(time.Second * 1)
|
||||||
}
|
}
|
||||||
if len(resource.Status) > 0 {
|
if len(resource.Status) > 0 {
|
||||||
|
|||||||
@@ -214,7 +214,6 @@ func (optimizer *Optimizer) predict(job string, seq int) (OptimizerJobExecutionT
|
|||||||
|
|
||||||
var res MsgOptimizerPredict
|
var res MsgOptimizerPredict
|
||||||
err = json.Unmarshal([]byte(string(body)), &res)
|
err = json.Unmarshal([]byte(string(body)), &res)
|
||||||
log.Println(res)
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
return OptimizerJobExecutionTime{Total: res.Total, Pre: res.Pre, Main: res.Main, Post: res.Post}, true
|
return OptimizerJobExecutionTime{Total: res.Total, Pre: res.Pre, Main: res.Main, Post: res.Post}, true
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user