diff --git a/pkg/api/v1alpha1/cluster.go b/pkg/api/v1alpha1/cluster.go index 84bc48d96470..267c686e8d0d 100644 --- a/pkg/api/v1alpha1/cluster.go +++ b/pkg/api/v1alpha1/cluster.go @@ -229,7 +229,7 @@ func GetAndValidateClusterConfig(fileName string) (*Cluster, error) { // GetClusterDefaultKubernetesVersion returns the default kubernetes version for a Cluster. func GetClusterDefaultKubernetesVersion() KubernetesVersion { - return Kube130 + return Kube131 } // ValidateClusterConfigContent validates a Cluster object without modifying it diff --git a/pkg/api/v1alpha1/cluster_test.go b/pkg/api/v1alpha1/cluster_test.go index 8277d24ee73d..d5f2b0c14238 100644 --- a/pkg/api/v1alpha1/cluster_test.go +++ b/pkg/api/v1alpha1/cluster_test.go @@ -4026,7 +4026,7 @@ func TestValidateEksaVersion(t *testing.T) { func TestGetClusterDefaultKubernetesVersion(t *testing.T) { g := NewWithT(t) - g.Expect(GetClusterDefaultKubernetesVersion()).To(Equal(Kube130)) + g.Expect(GetClusterDefaultKubernetesVersion()).To(Equal(Kube131)) } func TestClusterWorkerNodeConfigCount(t *testing.T) { diff --git a/pkg/api/v1alpha1/testdata/cluster_in_place_upgrade.yaml b/pkg/api/v1alpha1/testdata/cluster_in_place_upgrade.yaml index 069c9a667452..f47c9bb02253 100644 --- a/pkg/api/v1alpha1/testdata/cluster_in_place_upgrade.yaml +++ b/pkg/api/v1alpha1/testdata/cluster_in_place_upgrade.yaml @@ -17,7 +17,7 @@ spec: upgradeRolloutStrategy: type: InPlace datacenterRef: {} - kubernetesVersion: "1.30" + kubernetesVersion: "1.31" managementCluster: name: test-cluster workerNodeGroupConfigurations: diff --git a/pkg/features/features.go b/pkg/features/features.go index 94265b6d38be..7cb88ec06d58 100644 --- a/pkg/features/features.go +++ b/pkg/features/features.go @@ -8,7 +8,6 @@ const ( UseControllerForCli = "USE_CONTROLLER_FOR_CLI" VSphereInPlaceEnvVar = "VSPHERE_IN_PLACE_UPGRADE" APIServerExtraArgsEnabledEnvVar = "API_SERVER_EXTRA_ARGS_ENABLED" - K8s131SupportEnvVar = "K8S_1_31_SUPPORT" ) func FeedGates(featureGates []string) { @@ -65,11 +64,3 @@ func APIServerExtraArgsEnabled() Feature { IsActive: globalFeatures.isActiveForEnvVar(APIServerExtraArgsEnabledEnvVar), } } - -// K8s131Support is the feature flag for Kubernetes 1.31 support. -func K8s131Support() Feature { - return Feature{ - Name: "Kubernetes version 1.31 support", - IsActive: globalFeatures.isActiveForEnvVar(K8s131SupportEnvVar), - } -} diff --git a/pkg/features/features_test.go b/pkg/features/features_test.go index 0ad103953363..739d5f4c146c 100644 --- a/pkg/features/features_test.go +++ b/pkg/features/features_test.go @@ -85,11 +85,3 @@ func TestAPIServerExtraArgsEnabledFeatureFlag(t *testing.T) { g.Expect(os.Setenv(APIServerExtraArgsEnabledEnvVar, "true")).To(Succeed()) g.Expect(IsActive(APIServerExtraArgsEnabled())).To(BeTrue()) } - -func TestWithK8s131FeatureFlag(t *testing.T) { - g := NewWithT(t) - setupContext(t) - - g.Expect(os.Setenv(K8s131SupportEnvVar, "true")).To(Succeed()) - g.Expect(IsActive(K8s131Support())).To(BeTrue()) -} diff --git a/pkg/validations/cluster.go b/pkg/validations/cluster.go index fb37d45514bd..bed960fa2624 100644 --- a/pkg/validations/cluster.go +++ b/pkg/validations/cluster.go @@ -10,7 +10,6 @@ import ( "github.com/aws/eks-anywhere/pkg/cluster" "github.com/aws/eks-anywhere/pkg/config" "github.com/aws/eks-anywhere/pkg/constants" - "github.com/aws/eks-anywhere/pkg/features" "github.com/aws/eks-anywhere/pkg/logger" "github.com/aws/eks-anywhere/pkg/providers" "github.com/aws/eks-anywhere/pkg/providers/common" @@ -287,13 +286,3 @@ func ValidateBottlerocketKubeletConfig(spec *cluster.Spec) error { return nil } - -// ValidateK8s131Support checks if the 1.31 feature flag is set when using k8s 1.31. -func ValidateK8s131Support(clusterSpec *cluster.Spec) error { - if !features.IsActive(features.K8s131Support()) { - if clusterSpec.Cluster.Spec.KubernetesVersion == v1alpha1.Kube131 { - return fmt.Errorf("kubernetes version %s is not enabled. Please set the env variable %v", v1alpha1.Kube131, features.K8s131SupportEnvVar) - } - } - return nil -} diff --git a/pkg/validations/cluster_test.go b/pkg/validations/cluster_test.go index b01b23e81119..ba184169b74e 100644 --- a/pkg/validations/cluster_test.go +++ b/pkg/validations/cluster_test.go @@ -16,7 +16,6 @@ import ( "github.com/aws/eks-anywhere/internal/test" anywherev1 "github.com/aws/eks-anywhere/pkg/api/v1alpha1" "github.com/aws/eks-anywhere/pkg/cluster" - "github.com/aws/eks-anywhere/pkg/features" "github.com/aws/eks-anywhere/pkg/providers" providermocks "github.com/aws/eks-anywhere/pkg/providers/mocks" "github.com/aws/eks-anywhere/pkg/types" @@ -838,18 +837,3 @@ func TestValidateBottlerocketKC(t *testing.T) { }) } } - -func TestValidateK8s131Support(t *testing.T) { - tt := newTest(t) - tt.clusterSpec.Cluster.Spec.KubernetesVersion = anywherev1.Kube131 - tt.Expect(validations.ValidateK8s131Support(tt.clusterSpec)).To( - MatchError(ContainSubstring("kubernetes version 1.31 is not enabled. Please set the env variable K8S_1_31_SUPPORT"))) -} - -func TestValidateK8s131SupportActive(t *testing.T) { - tt := newTest(t) - tt.clusterSpec.Cluster.Spec.KubernetesVersion = anywherev1.Kube131 - features.ClearCache() - os.Setenv(features.K8s131SupportEnvVar, "true") - tt.Expect(validations.ValidateK8s131Support(tt.clusterSpec)).To(Succeed()) -} diff --git a/pkg/validations/createvalidations/preflightvalidations.go b/pkg/validations/createvalidations/preflightvalidations.go index b5cdd6c35815..53002e389b0b 100644 --- a/pkg/validations/createvalidations/preflightvalidations.go +++ b/pkg/validations/createvalidations/preflightvalidations.go @@ -8,7 +8,6 @@ import ( anywherev1 "github.com/aws/eks-anywhere/pkg/api/v1alpha1" "github.com/aws/eks-anywhere/pkg/config" "github.com/aws/eks-anywhere/pkg/constants" - "github.com/aws/eks-anywhere/pkg/features" "github.com/aws/eks-anywhere/pkg/types" "github.com/aws/eks-anywhere/pkg/validations" ) @@ -51,14 +50,6 @@ func (v *CreateValidations) PreflightValidations(ctx context.Context) []validati Err: validations.ValidateEksaVersion(ctx, v.Opts.CliVersion, v.Opts.Spec), } }, - func() *validations.ValidationResult { - return &validations.ValidationResult{ - Name: "validate kubernetes version 1.31 support", - Remediation: fmt.Sprintf("ensure %v env variable is set", features.K8s131SupportEnvVar), - Err: validations.ValidateK8s131Support(v.Opts.Spec), - Silent: true, - } - }, } if len(v.Opts.Spec.VSphereMachineConfigs) != 0 { diff --git a/pkg/validations/upgradevalidations/preflightvalidations.go b/pkg/validations/upgradevalidations/preflightvalidations.go index 8e01df69fde4..46dad6c2e6f6 100644 --- a/pkg/validations/upgradevalidations/preflightvalidations.go +++ b/pkg/validations/upgradevalidations/preflightvalidations.go @@ -9,7 +9,6 @@ import ( anywherev1 "github.com/aws/eks-anywhere/pkg/api/v1alpha1" "github.com/aws/eks-anywhere/pkg/config" "github.com/aws/eks-anywhere/pkg/constants" - "github.com/aws/eks-anywhere/pkg/features" "github.com/aws/eks-anywhere/pkg/providers" "github.com/aws/eks-anywhere/pkg/types" "github.com/aws/eks-anywhere/pkg/validation" @@ -123,14 +122,6 @@ func (u *UpgradeValidations) PreflightValidations(ctx context.Context) []validat Err: validations.ValidatePauseAnnotation(ctx, k, targetCluster, targetCluster.Name), } }, - func() *validations.ValidationResult { - return &validations.ValidationResult{ - Name: "validate kubernetes version 1.31 support", - Remediation: fmt.Sprintf("ensure %v env variable is set", features.K8s131SupportEnvVar), - Err: validations.ValidateK8s131Support(u.Opts.Spec), - Silent: true, - } - }, } if len(u.Opts.Spec.VSphereMachineConfigs) != 0 { diff --git a/test/framework/cluster.go b/test/framework/cluster.go index a38cf4f1cdf4..4056a7517d6b 100644 --- a/test/framework/cluster.go +++ b/test/framework/cluster.go @@ -36,7 +36,6 @@ import ( "github.com/aws/eks-anywhere/pkg/cluster" "github.com/aws/eks-anywhere/pkg/constants" "github.com/aws/eks-anywhere/pkg/executables" - "github.com/aws/eks-anywhere/pkg/features" "github.com/aws/eks-anywhere/pkg/filewriter" "github.com/aws/eks-anywhere/pkg/git" "github.com/aws/eks-anywhere/pkg/providers/cloudstack/decoder" @@ -2203,12 +2202,11 @@ func dumpFile(description, path string, t T) { func (e *ClusterE2ETest) setFeatureFlagForUnreleasedKubernetesVersion(version v1alpha1.KubernetesVersion) { // Update this variable to equal the feature flagged k8s version when applicable. // For example, if k8s 1.31 is under a feature flag, we would set this to v1alpha1.Kube131 - unreleasedK8sVersion := v1alpha1.Kube131 + var unreleasedK8sVersion v1alpha1.KubernetesVersion if version == unreleasedK8sVersion { // Set feature flag for the unreleased k8s version when applicable e.T.Logf("Setting k8s version support feature flag...") - os.Setenv(features.K8s131SupportEnvVar, "true") } }