chore: lifecycle action job supports default cluster tolerations (#7971)

Author: Y-Rookie

controllers/apps/operations/switchover_util.go

@@ -225,8 +225,8 @@ func renderSwitchoverCmdJob(ctx context.Context,
 		for i := range job.Spec.Template.Spec.Containers {
 			intctrlutil.InjectZeroResourcesLimitsIfEmpty(&job.Spec.Template.Spec.Containers[i])
 		}
-		if len(cluster.Spec.Tolerations) > 0 {
-			job.Spec.Template.Spec.Tolerations = cluster.Spec.Tolerations
+		if err := component.BuildJobTolerations(job, cluster); err != nil {
+			return nil, err
 		}
 		return job, nil
 	}

pkg/controller/component/action_utils.go

@@ -21,6 +21,7 @@ package component
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"strings"
 	"time"
@@ -39,6 +40,7 @@ import (
 	"github.com/apecloud/kubeblocks/pkg/controller/job"
 	"github.com/apecloud/kubeblocks/pkg/controller/model"
 	intctrlutil "github.com/apecloud/kubeblocks/pkg/controllerutil"
+	viper "github.com/apecloud/kubeblocks/pkg/viperx"
 )
 
 // LifeCycleActionType represents the lifecycle action type.
@@ -216,8 +218,8 @@ func renderActionCmdJob(ctx context.Context, cli client.Reader, actionCtx *Actio
 				},
 			},
 		}
-		if len(actionCtx.cluster.Spec.Tolerations) > 0 {
-			jobObj.Spec.Template.Spec.Tolerations = actionCtx.cluster.Spec.Tolerations
+		if err := BuildJobTolerations(jobObj, actionCtx.cluster); err != nil {
+			return nil, err
 		}
 		for i := range jobObj.Spec.Template.Spec.Containers {
 			intctrlutil.InjectZeroResourcesLimitsIfEmpty(&jobObj.Spec.Template.Spec.Containers[i])
@@ -241,6 +243,34 @@ func renderActionCmdJob(ctx context.Context, cli client.Reader, actionCtx *Actio
 	return renderedJob, nil
 }
 
+// BuildJobTolerations builds the job tolerations.
+func BuildJobTolerations(job *batchv1.Job, cluster *appsv1alpha1.Cluster) error {
+	// build data plane tolerations from config
+	var tolerations []corev1.Toleration
+	if val := viper.GetString(constant.CfgKeyDataPlaneTolerations); val != "" {
+		if err := json.Unmarshal([]byte(val), &tolerations); err != nil {
+			return err
+		}
+	}
+
+	if len(job.Spec.Template.Spec.Tolerations) > 0 {
+		job.Spec.Template.Spec.Tolerations = append(job.Spec.Template.Spec.Tolerations, tolerations...)
+	} else {
+		job.Spec.Template.Spec.Tolerations = tolerations
+	}
+
+	// build job tolerations from legacy cluster.spec.Tolerations
+	if len(cluster.Spec.Tolerations) > 0 {
+		job.Spec.Template.Spec.Tolerations = append(job.Spec.Template.Spec.Tolerations, cluster.Spec.Tolerations...)
+	}
+
+	// build job tolerations from cluster.spec.SchedulingPolicy.Tolerations
+	if cluster.Spec.SchedulingPolicy != nil && len(cluster.Spec.SchedulingPolicy.Tolerations) > 0 {
+		job.Spec.Template.Spec.Tolerations = append(job.Spec.Template.Spec.Tolerations, cluster.Spec.SchedulingPolicy.Tolerations...)
+	}
+	return nil
+}
+
 // buildLifecycleActionEnvs builds the environment variables for lifecycle actions.
 func buildLifecycleActionEnvs(ctx context.Context,
 	cli client.Reader,