diff --git a/api/internal/logic/schedule/schedulesubmitlogic.go b/api/internal/logic/schedule/schedulesubmitlogic.go
index b2759a0c..5ce7a6ee 100644
--- a/api/internal/logic/schedule/schedulesubmitlogic.go
+++ b/api/internal/logic/schedule/schedulesubmitlogic.go
@@ -45,7 +45,6 @@ func (l *ScheduleSubmitLogic) ScheduleSubmit(req *types.ScheduleReq) (resp *type
 		Params:                req.AiOption.Params,
 		Envs:                  req.AiOption.Envs,
 		Cmd:                   req.AiOption.Cmd,
-		ClusterIds:            req.AiOption.AiClusterIds,
 	}
 	aiSchdl, err := schedulers.NewAiScheduler(l.ctx, "", l.svcCtx.Scheduler, opt)
 	if err != nil {
diff --git a/api/internal/scheduler/schedulers/aiScheduler.go b/api/internal/scheduler/schedulers/aiScheduler.go
index 3d3c78ef..7d88ed5e 100644
--- a/api/internal/scheduler/schedulers/aiScheduler.go
+++ b/api/internal/scheduler/schedulers/aiScheduler.go
@@ -26,6 +26,7 @@ import (
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/scheduler/schedulers/option"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/scheduler/service/collector"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/scheduler/strategy"
+	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/scheduler/strategy/param"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/pkg/response"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/constants"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/models"
@@ -90,38 +91,38 @@ func (as *AiScheduler) PickOptimalStrategy() (strategy.Strategy, error) {
 		return &strategy.SingleAssignment{Cluster: &strategy.AssignedCluster{ClusterId: as.option.ClusterIds[0], Replicas: 1}}, nil
 	}
 
-	/*	resources, err := as.findClustersWithResources()
+	resources, err := as.findClustersWithResources()
 
-		if err != nil {
-			return nil, err
-		}
-		if len(resources) == 0 {
-			return nil, errors.New("no cluster has resources")
-		}
+	if err != nil {
+		return nil, err
+	}
+	if len(resources) == 0 {
+		return nil, errors.New("no cluster has resources")
+	}
 
-		if len(resources) == 1 {
-			var cluster strategy.AssignedCluster
-			cluster.ClusterId = resources[0].ClusterId
-			cluster.Replicas = 1
-			return &strategy.SingleAssignment{Cluster: &cluster}, nil
-		}
+	if len(resources) == 1 {
+		var cluster strategy.AssignedCluster
+		cluster.ClusterId = resources[0].ClusterId
+		cluster.Replicas = 1
+		return &strategy.SingleAssignment{Cluster: &cluster}, nil
+	}
 
-		params := &param.Params{Resources: resources}*/
+	params := &param.Params{Resources: resources}
 
 	switch as.option.StrategyName {
 	case strategy.REPLICATION:
 		var clusterIds []string
-		/*	for _, resource := range resources {
+		for _, resource := range resources {
 			clusterIds = append(clusterIds, resource.ClusterId)
-		}*/
+		}
 		strategy := strategy.NewReplicationStrategy(clusterIds, 1)
 		return strategy, nil
-		/*	case strategy.RESOURCES_PRICING:
-				strategy := strategy.NewPricingStrategy(&param.ResourcePricingParams{Params: params, Replicas: 1})
-				return strategy, nil
-			case strategy.DYNAMIC_RESOURCES:
-				strategy := strategy.NewDynamicResourcesStrategy(params.Resources, as.option, 1)
-				return strategy, nil*/
+	case strategy.RESOURCES_PRICING:
+		strategy := strategy.NewPricingStrategy(&param.ResourcePricingParams{Params: params, Replicas: 1})
+		return strategy, nil
+	case strategy.DYNAMIC_RESOURCES:
+		strategy := strategy.NewDynamicResourcesStrategy(params.Resources, as.option, 1)
+		return strategy, nil
 	case strategy.STATIC_WEIGHT:
 		//todo resources should match cluster StaticWeightMap
 		strategy := strategy.NewStaticWeightStrategy(as.option.ClusterToStaticWeight, as.option.Replica)