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

Merge pull request 'updated shuguang deployinstance logics' (#307) from tzwang/pcm-coordinator:master into master 

Former-commit-id: abcac3579eafcc73bd85e5eab87f94d037bf3235
This commit is contained in:
tzwang 2024-09-13 15:41:42 +08:00
parent 9b142e6ba1 a525685907
commit 97d2af6f2d
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/scheduler/service/inference/imageInference/imageInference.go
View File

@ -240,7 +240,7 @@ func (i *ImageInference) inferImages(cs []*FilteredCluster) ([]*types.ImageResul
var wg sync.WaitGroup var wg sync.WaitGroup
var ch = make(chan *types.ImageResult, len(i.files)) var ch = make(chan *types.ImageResult, len(i.files))
var results []*types.ImageResult var results []*types.ImageResult
limit := make(chan bool, 7) limit := make(chan bool, 5)
var imageNumIdx int32 = 0 var imageNumIdx int32 = 0
var imageNumIdxEnd int32 = 0 var imageNumIdxEnd int32 = 0
@ -396,7 +396,6 @@ func (i *ImageInference) sendInferReq(images []*ImageFile, cluster *FilteredClus
return return
} }
}(image, cluster) }(image, cluster)
<-limit
} }
} }

3
internal/storeLink/shuguangai.go
View File

@ -801,8 +801,11 @@ func (s *ShuguangAi) GetInferDeployInstanceList(ctx context.Context) ([]*inferen
var insList []*inference.DeployInstance var insList []*inference.DeployInstance
params := &hpcAC.GetInstanceServiceListReqParam{ params := &hpcAC.GetInstanceServiceListReqParam{
InstanceServiceName: DEPLOY_INSTANCE_PREFIEX, InstanceServiceName: DEPLOY_INSTANCE_PREFIEX,
Status: "",
TaskType: "",
Start: 0, Start: 0,
Limit: DEPLOY_INSTANCE_LIMIT, Limit: DEPLOY_INSTANCE_LIMIT,
Sort: "desc",
} }
req := &hpcacclient.GetInstanceServiceListReq{ req := &hpcacclient.GetInstanceServiceListReq{
Param: params, Param: params,