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

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

Former-commit-id: b2e2007bfeb3b98cebef10694cd9a21ba63f747a
This commit is contained in:
tzwang 2024-05-16 18:22:20 +08:00
parent 2259fc5c8b 02f991ec1a
commit ed8889a6f9
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/internal/scheduler/schedulers/aiScheduler.go
View File

@ -129,6 +129,7 @@ func (as *AiScheduler) AssignTask(clusters []*strategy.AssignedCluster) (interfa
var wg sync.WaitGroup var wg sync.WaitGroup
var results []*AiResult var results []*AiResult
var mu sync.Mutex
var errs []interface{} var errs []interface{}
var taskNum int32 var taskNum int32
for _, cluster := range clusters { for _, cluster := range clusters {
@ -158,7 +159,10 @@ func (as *AiScheduler) AssignTask(clusters []*strategy.AssignedCluster) (interfa
return return
} }
mu.Lock()
result, _ := convertType(resp) result, _ := convertType(resp)
mu.Unlock()
result.Replica = c.Replicas result.Replica = c.Replicas
result.ClusterId = c.ClusterId result.ClusterId = c.ClusterId
result.Strategy = as.option.StrategyName result.Strategy = as.option.StrategyName