fix aischeduler bugs

Former-commit-id: 4df953f2a614800510376210d69f82a646cae02f
This commit is contained in:
tzwang 2024-05-16 18:17:57 +08:00
parent fffc3b9718
commit f8a4656d83
1 changed files with 4 additions and 0 deletions

View File

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