From f498b7a68ee4d840cf011459057d281ff2827b32 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 19:58:38 +0800 Subject: [PATCH] update --- src/job_manager.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/job_manager.go b/src/job_manager.go index f23a5d1..339ed10 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -151,7 +151,7 @@ func (jm *JobManager) start() { /* monitor job execution */ for { - res := jm.status() + //res := jm.status() flag := false onlyPS := true for i := range res.Status { @@ -266,6 +266,7 @@ func (jm *JobManager) status() MsgJobStatus { err := spider.do() if err != nil { + tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}} continue } @@ -273,12 +274,14 @@ func (jm *JobManager) status() MsgJobStatus { body, err := ioutil.ReadAll(resp.Body) resp.Body.Close() if err != nil { + tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}} continue } var res MsgTaskStatus err = json.Unmarshal([]byte(string(body)), &res) if err != nil { + tasksStatus[i] = TaskStatus{Status: "unknown", State: map[string]interface{}{"ExitCode": float64(-1)}} continue } res.Status.Node = taskStatus.Node