diff --git a/ray-operator/controllers/ray/utils/validation.go b/ray-operator/controllers/ray/utils/validation.go index a3e6da66e80..652ff0e14b6 100644 --- a/ray-operator/controllers/ray/utils/validation.go +++ b/ray-operator/controllers/ray/utils/validation.go @@ -193,7 +193,7 @@ func ValidateRayClusterSpec(spec *rayv1.RayClusterSpec, annotations map[string]s if IsAuthEnabled(spec) { if spec.RayVersion == "" { - return fmt.Errorf("authOptions.mode is 'token' but RayVersion was not specified. Ray version 2.51.0 or later is required") + return fmt.Errorf("authOptions.mode is 'token' but RayVersion was not specified. Ray version 2.52.0 or later is required") } rayVersion, err := version.ParseGeneric(spec.RayVersion) @@ -201,10 +201,10 @@ func ValidateRayClusterSpec(spec *rayv1.RayClusterSpec, annotations map[string]s return fmt.Errorf("authOptions.mode is 'token' but RayVersion format is invalid: %s, %w", spec.RayVersion, err) } - // Require minimum Ray version 2.51.0 - minVersion := version.MustParseGeneric("2.51.0") + // Require minimum Ray version 2.52.0 + minVersion := version.MustParseGeneric("2.52.0") if rayVersion.LessThan(minVersion) { - return fmt.Errorf("authOptions.mode is 'token' but minimum Ray version is 2.51.0, got %s", spec.RayVersion) + return fmt.Errorf("authOptions.mode is 'token' but minimum Ray version is 2.52.0, got %s", spec.RayVersion) } } diff --git a/ray-operator/controllers/ray/utils/validation_test.go b/ray-operator/controllers/ray/utils/validation_test.go index 494fe39c29c..014d0917d68 100644 --- a/ray-operator/controllers/ray/utils/validation_test.go +++ b/ray-operator/controllers/ray/utils/validation_test.go @@ -858,11 +858,6 @@ func TestValidateRayClusterSpecRayVersionForAuth(t *testing.T) { errorMessage string expectError bool }{ - { - name: "Valid Ray version 2.51.0", - rayVersion: "2.51.0", - expectError: false, - }, { name: "Valid Ray version 2.52.0", rayVersion: "2.52.0", @@ -877,7 +872,7 @@ func TestValidateRayClusterSpecRayVersionForAuth(t *testing.T) { name: "Invalid Ray version 2.50.0", rayVersion: "2.50.0", expectError: true, - errorMessage: "authOptions.mode is 'token' but minimum Ray version is 2.51.0, got 2.50.0", + errorMessage: "authOptions.mode is 'token' but minimum Ray version is 2.52.0, got 2.50.0", }, { name: "Invalid Ray version format", @@ -889,7 +884,7 @@ func TestValidateRayClusterSpecRayVersionForAuth(t *testing.T) { name: "Empty Ray version", rayVersion: "", expectError: true, - errorMessage: "authOptions.mode is 'token' but RayVersion was not specified. Ray version 2.51.0 or later is required", + errorMessage: "authOptions.mode is 'token' but RayVersion was not specified. Ray version 2.52.0 or later is required", }, } diff --git a/ray-operator/test/e2e/raycluster_auth_test.go b/ray-operator/test/e2e/raycluster_auth_test.go index 67f2a7e4113..de37e401209 100644 --- a/ray-operator/test/e2e/raycluster_auth_test.go +++ b/ray-operator/test/e2e/raycluster_auth_test.go @@ -28,7 +28,7 @@ func TestRayClusterAuthOptions(t *testing.T) { t.Parallel() rayClusterAC := rayv1ac.RayCluster("raycluster-auth-token", namespace.Name). - WithSpec(NewRayClusterSpecWithAuth(rayv1.AuthModeToken).WithRayVersion("2.51")) + WithSpec(NewRayClusterSpecWithAuth(rayv1.AuthModeToken).WithRayVersion("2.52")) rayCluster, err := test.Client().Ray().RayV1().RayClusters(namespace.Name).Apply(test.Ctx(), rayClusterAC, TestApplyOptions) g.Expect(err).NotTo(HaveOccurred())