update

src/job_manager.go

@@ -124,6 +124,9 @@ func (jm *JobManager) start() {
 			log.Warn(err)
 			continue
 		}
+		if res.Code != 0 {
+			log.Warn(err)
+		}
 
 		jm.jobStatus.tasks[jm.job.Tasks[i].Name] = TaskStatus{Id: res.Id, Node: jm.resources[i].ClientHost}
 	}

src/util.go

@@ -131,7 +131,7 @@ type Job struct {
 	CreatedAt int         `json:"created_at"`
 	UpdatedAt int         `json:"updated_at"`
 	CreatedBy int         `json:"created_by"`
-	Locality  int         `json:"created_by"`
+	Locality  int         `json:"locality"`
 	Status    State       `json:"status"`
 }