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

Merge pull request 'fix tasklist bugs' (#250) from tzwang/pcm-coordinator:master into master 

Former-commit-id: d822ad04d4e16856806552a6ca3f849353bdeb37
This commit is contained in:
tzwang 2024-06-25 22:59:06 +08:00
parent 7cdd089dd8 c2f5349f5c
commit 86397eb0a6
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
api/internal/logic/core/pagelisttasklogic.go
View File

@ -57,9 +57,9 @@ func (l *PageListTaskLogic) PageListTask(req *types.PageTaskReq) (resp *types.Pa
} }
// 更新智算任务状态 // 更新智算任务状态
chs := [2]chan struct{}{make(chan struct{}), make(chan struct{})} //chs := [2]chan struct{}{make(chan struct{}), make(chan struct{})}
go l.updateTaskStatus(list, chs[0]) //go l.updateTaskStatus(list, chs[0])
go l.updateAiTaskStatus(list, chs[1]) //go l.updateAiTaskStatus(list, chs[1])
for _, model := range list { for _, model := range list {
if model.StartTime != "" && model.EndTime == "" { if model.StartTime != "" && model.EndTime == "" {
@ -77,12 +77,12 @@ func (l *PageListTaskLogic) PageListTask(req *types.PageTaskReq) (resp *types.Pa
resp.PageNum = req.PageNum resp.PageNum = req.PageNum
resp.Total = total resp.Total = total
for _, ch := range chs { //for _, ch := range chs {
select { // select {
case <-ch: // case <-ch:
case <-time.After(1 * time.Second): // case <-time.After(1 * time.Second):
} // }
} //}
return return
} }