From e0fa22f2b5fe000e5dff9802769390cb7eabca44 Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 24 May 2020 01:46:57 +0800 Subject: [PATCH] update --- src/job_manager.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/job_manager.go b/src/job_manager.go index 4e73c44..dca8827 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -178,6 +178,13 @@ func (jm *JobManager) checkStatus(status []TaskStatus) bool { if !jm.job.Tasks[i].IsPS { onlyPS = false } + } else if status[i].Status == "unknown" { + log.Debug(jm.job.Name, "-", i, " is starting") + flag = true + if !jm.job.Tasks[i].IsPS { + onlyPS = false + } + InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, status[i]) } else if status[i].Status == "running" { log.Debug(jm.job.Name, "-", i, " is running") flag = true