floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'updated deployinstancelogics' (#296) from tzwang/pcm-coordinator:master into master 

Former-commit-id: 5e906a797da0394ecad6a1aaf8e07c878bda88fc
This commit is contained in:
tzwang 2024-08-30 15:31:10 +08:00
parent c0092c1a14 93b446714e
commit 637c4a69fe
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
internal/logic/inference/deployinstancelistlogic.go
View File

@ -59,23 +59,21 @@ func (l *DeployInstanceListLogic) DeployInstanceList(req *types.DeployInstanceLi
} }
list := common.ConcatMultipleSlices(slices) list := common.ConcatMultipleSlices(slices)
if len(list) == 0 { if len(list) != 0 {
return go updater.UpdateDeployInstanceStatusBatch(l.svcCtx, list)
}
go updater.UpdateDeployInstanceStatusBatch(l.svcCtx, list) ins := list[0]
for i := range list {
ins := list[0] uTime, _ := time.Parse(time.RFC3339, ins.UpdateTime)
for i := range list { latest, _ := time.Parse(time.RFC3339, list[i].UpdateTime)
uTime, _ := time.Parse(time.RFC3339, ins.UpdateTime) if latest.After(uTime) {
latest, _ := time.Parse(time.RFC3339, list[i].UpdateTime) ins = list[i]
if latest.After(uTime) { }
ins = list[i]
} }
}
go updater.UpdateDeployInstanceStatus(l.svcCtx, ins, true) go updater.UpdateDeployInstanceStatus(l.svcCtx, ins, true)
go updater.UpdateDeployTaskStatus(l.svcCtx) go updater.UpdateDeployTaskStatus(l.svcCtx)
}
resp.List = &deployTasks resp.List = &deployTasks
resp.PageSize = req.PageSize resp.PageSize = req.PageSize