From b79e43ab06855f879c5524921676c4f47ef01ede Mon Sep 17 00:00:00 2001 From: Newnius Date: Sat, 2 May 2020 22:35:31 +0800 Subject: [PATCH] update --- src/job_manager.go | 3 +++ src/util.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/job_manager.go b/src/job_manager.go index dfe31de..e148449 100644 --- a/src/job_manager.go +++ b/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} } diff --git a/src/util.go b/src/util.go index da62834..17230ef 100644 --- a/src/util.go +++ b/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"` }