updated shuguang InferDeployInstance logic

Former-commit-id: 8a1f7bd76a21d72b85e3ed59cb01579f9ae601ce
This commit is contained in:
tzwang 2024-09-13 15:42:11 +08:00
parent 5a15db9499
commit a525685907
2 changed files with 4 additions and 2 deletions

View File

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

View File

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