From c295f9eb6f6cdc5f97ca3aba25eabad66e504799 Mon Sep 17 00:00:00 2001 From: Newnius Date: Fri, 1 May 2020 13:01:53 +0800 Subject: [PATCH] update --- src/job_manager.go | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index c91a418..167603e 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -129,14 +129,17 @@ func (jm *JobManager) start() { //} /* return resource */ - jm.scheduler.ReleaseResource(jm.job, jm.resources[i]) - log.Info("return resource ", jm.resources[i].ClientID) + if jm.resources[i].ClientID != "null" { + jm.scheduler.ReleaseResource(jm.job, jm.resources[i]) + log.Info("return resource ", jm.resources[i].ClientID) + jm.resources[i].ClientID = "null" - for _, t := range jm.resources[i].Status { - jm.scheduler.Detach(t.UUID, jm.job.Name) + for _, t := range jm.resources[i].Status { + jm.scheduler.Detach(t.UUID, jm.job.Name) + } + + InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i]) } - - InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i]) } } if flag && onlyPS {