From eda386fdf6afe56a2da0c64c13fada74b2801620 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 29 Jun 2020 23:38:58 +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 ea6f8d2..fc098ba 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -331,7 +331,7 @@ func (jm *JobManager) logs(taskName string) MsgLog { func (jm *JobManager) status() MsgJobStatus { var tasksStatus []TaskStatus for range jm.job.Tasks { //append would cause uncertain order - tasksStatus = append(tasksStatus, TaskStatus{TimeStamp: time.Now().Unix()}) + tasksStatus = append(tasksStatus, TaskStatus{}) } for i, task := range jm.job.Tasks { @@ -380,6 +380,9 @@ func (jm *JobManager) status() MsgJobStatus { res.Status.Node = taskStatus.Node tasksStatus[i] = res.Status } + for i := range jm.job.Tasks { + tasksStatus[i].TimeStamp = time.Now().Unix() + } if jm.isRunning { go func() {