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

fix aicenter bugs 

Former-commit-id: d9185bf8675a7e4e3cfb470d1dd7b54dd15a2cf9
This commit is contained in:
tzwang 2024-05-20 19:10:43 +08:00
parent 766c862af7
commit 6b6aa42d01
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
api/internal/logic/ai/getcenteroverviewlogic.go
View File

@ -99,11 +99,20 @@ func (l *GetCenterOverviewLogic) updateClusterResource(mu *sync.RWMutex, ch chan
} }
wg.Add(1) wg.Add(1)
go func() { go func() {
_, ok := l.svcCtx.Scheduler.AiService.AiCollectorAdapterMap[adapter.Id][c.Id]
if !ok {
wg.Done()
return
}
stat, err := l.svcCtx.Scheduler.AiService.AiCollectorAdapterMap[adapter.Id][c.Id].GetResourceStats(l.ctx) stat, err := l.svcCtx.Scheduler.AiService.AiCollectorAdapterMap[adapter.Id][c.Id].GetResourceStats(l.ctx)
if err != nil { if err != nil {
wg.Done() wg.Done()
return return
} }
if stat == nil {
wg.Done()
return
}
clusterType, err := strconv.ParseInt(adapter.Type, 10, 64) clusterType, err := strconv.ParseInt(adapter.Type, 10, 64)
if err != nil { if err != nil {
wg.Done() wg.Done()

3
api/internal/logic/ai/getcenterqueueinglogic.go
View File

@ -42,6 +42,9 @@ func (l *GetCenterQueueingLogic) GetCenterQueueing() (resp *types.CenterQueueing
if err != nil { if err != nil {
continue continue
} }
if queues == nil {
continue
}
//todo sync current task queues //todo sync current task queues
current := &types.CenterQueue{ current := &types.CenterQueue{
Name: cluster.Name, Name: cluster.Name,