YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-15 08:16:43 +00:00
Code Issues Releases Wiki Activity

update

Browse Source
This commit is contained in:
Newnius
2020-05-04 19:58:38 +08:00
parent 4668cf8b4f
commit f498b7a68e
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/job_manager.go
View File

@@ -151,7 +151,7 @@ func (jm *JobManager) start() {
/* monitor job execution */ /* monitor job execution */
for { for {
res := jm.status() //res := jm.status()
flag := false flag := false
onlyPS := true onlyPS := true
for i := range res.Status { for i := range res.Status {
@@ -266,6 +266,7 @@ func (jm *JobManager) status() MsgJobStatus {
err := spider.do() err := spider.do()
if err != nil { if err != nil {
tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}}
continue continue
} }
@@ -273,12 +274,14 @@ func (jm *JobManager) status() MsgJobStatus {
body, err := ioutil.ReadAll(resp.Body) body, err := ioutil.ReadAll(resp.Body)
resp.Body.Close() resp.Body.Close()
if err != nil { if err != nil {
tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}}
continue continue
} }
var res MsgTaskStatus var res MsgTaskStatus
err = json.Unmarshal([]byte(string(body)), &res) err = json.Unmarshal([]byte(string(body)), &res)
if err != nil { if err != nil {
tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}}
continue continue
} }
res.Status.Node = taskStatus.Node res.Status.Node = taskStatus.Node