From 4b21b863c4fa8dd3a549d9bbdd7373022166f9da Mon Sep 17 00:00:00 2001 From: tzwang Date: Fri, 30 Aug 2024 15:30:02 +0800 Subject: [PATCH] updated deployinstancelistlogic --- .../inference/deployinstancelistlogic.go | 26 +++++++++---------- 1 file changed, 12 insertions(+), 14 deletions(-) diff --git a/internal/logic/inference/deployinstancelistlogic.go b/internal/logic/inference/deployinstancelistlogic.go index dc79c6450..053d2fe75 100644 --- a/internal/logic/inference/deployinstancelistlogic.go +++ b/internal/logic/inference/deployinstancelistlogic.go @@ -59,23 +59,21 @@ func (l *DeployInstanceListLogic) DeployInstanceList(req *types.DeployInstanceLi } list := common.ConcatMultipleSlices(slices) - if len(list) == 0 { - return - } + if len(list) != 0 { + go updater.UpdateDeployInstanceStatusBatch(l.svcCtx, list) - go updater.UpdateDeployInstanceStatusBatch(l.svcCtx, list) - - ins := list[0] - for i := range list { - uTime, _ := time.Parse(time.RFC3339, ins.UpdateTime) - latest, _ := time.Parse(time.RFC3339, list[i].UpdateTime) - if latest.After(uTime) { - ins = list[i] + ins := list[0] + for i := range list { + uTime, _ := time.Parse(time.RFC3339, ins.UpdateTime) + latest, _ := time.Parse(time.RFC3339, list[i].UpdateTime) + if latest.After(uTime) { + ins = list[i] + } } - } - go updater.UpdateDeployInstanceStatus(l.svcCtx, ins, true) - go updater.UpdateDeployTaskStatus(l.svcCtx) + go updater.UpdateDeployInstanceStatus(l.svcCtx, ins, true) + go updater.UpdateDeployTaskStatus(l.svcCtx) + } resp.List = &deployTasks resp.PageSize = req.PageSize