diff --git a/pkg/util/testingjobs/rayjob/wrappers.go b/pkg/util/testingjobs/rayjob/wrappers.go index da85e7fe00b..1790078c3ce 100644 --- a/pkg/util/testingjobs/rayjob/wrappers.go +++ b/pkg/util/testingjobs/rayjob/wrappers.go @@ -40,6 +40,7 @@ func MakeJob(name, ns string) *JobWrapper { Spec: rayv1.RayJobSpec{ ShutdownAfterJobFinishes: true, RayClusterSpec: &rayv1.RayClusterSpec{ + RayVersion: "2.9.0", HeadGroupSpec: rayv1.HeadGroupSpec{ RayStartParams: map[string]string{}, Template: corev1.PodTemplateSpec{ diff --git a/test/e2e/multikueue/e2e_test.go b/test/e2e/multikueue/e2e_test.go index a5b4919a99c..20bc1874c10 100644 --- a/test/e2e/multikueue/e2e_test.go +++ b/test/e2e/multikueue/e2e_test.go @@ -514,7 +514,6 @@ var _ = ginkgo.Describe("MultiKueue", func() { Request(rayv1.HeadNode, corev1.ResourceCPU, "1"). Request(rayv1.WorkerNode, corev1.ResourceCPU, "0.5"). Entrypoint("python -c \"import ray; ray.init(); print(ray.cluster_resources())\""). - RayVersion("2.9.0"). Image(rayv1.HeadNode, E2eKuberayTestImage, []string{}). Image(rayv1.WorkerNode, E2eKuberayTestImage, []string{}). Obj()