From d71f12295291eabef0a5d9577d167ab4e9e55fdf Mon Sep 17 00:00:00 2001 From: Newnius Date: Sat, 2 May 2020 22:52:01 +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 8f24fe4..029abaf 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -128,8 +128,11 @@ func (jm *JobManager) start() { if res.Code != 0 { log.Warn(res) } + if res.Code == 0 { + jm.jobStatus.tasks[jm.job.Tasks[i].Name] = TaskStatus{Id: res.Id, Node: jm.resources[i].ClientHost} + break + } } - jm.jobStatus.tasks[jm.job.Tasks[i].Name] = TaskStatus{Id: res.Id, Node: jm.resources[i].ClientHost} } /* monitor job execution */