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

fix tasklist bugs 

Former-commit-id: f97b9f3eac995728af77aff0bb174d7a3449a858
This commit is contained in:
tzwang 2024-06-25 22:55:12 +08:00
parent 27dd00af1c
commit c2f5349f5c
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
} }