提交代码

modules/cloudbrain/cloudbrain.go

@@ -241,6 +241,9 @@ func GenerateTask(req GenerateCloudBrainTaskReq) error {
 	//如果没有匹配到spec信息，尝试从专属资源池获取
 	if resourceSpec == nil && SpecialPools != nil {
 		for _, specialPool := range SpecialPools.Pools {
+			if resourceSpec != nil {
+				break
+			}
 			if specialPool.ResourceSpec != nil {
 				if IsElementExist(specialPool.JobType, req.JobType) && IsQueueInSpecialtPool(specialPool.Pool, req.GpuQueue) {
 					for _, spec := range specialPool.ResourceSpec {

routers/repo/cloudbrain.go

@@ -203,6 +203,7 @@ func cloudBrainNewDataPrepare(ctx *context.Context) error {
 							}
 						}
 					}
+					break
 				}
 			}