Skip to content

Commit 4a623fd

Browse files
[flaky] RayJob fails when head Pod is deleted when job is running (#4182)
Signed-off-by: Future-Outlier <[email protected]>
1 parent 87de75f commit 4a623fd

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

ray-operator/test/e2erayjob/rayjob_test.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -310,11 +310,10 @@ env_vars:
310310
g.Eventually(RayJob(test, rayJob.Namespace, rayJob.Name), TestTimeoutMedium).
311311
Should(WithTransform(RayJobDeploymentStatus, Equal(rayv1.JobDeploymentStatusFailed)))
312312
g.Eventually(RayJob(test, rayJob.Namespace, rayJob.Name), TestTimeoutMedium).
313-
Should(WithTransform(RayJobReason, Equal(rayv1.JobDeploymentStatusTransitionGracePeriodExceeded)))
314-
g.Eventually(RayJob(test, rayJob.Namespace, rayJob.Name), TestTimeoutMedium).
315-
Should(WithTransform(func(job *rayv1.RayJob) string { return job.Status.Message },
316-
MatchRegexp("The RayJob submitter finished at .* but the ray job did not reach terminal state within .*")))
317-
313+
Should(WithTransform(RayJobReason, Or(
314+
Equal(rayv1.JobDeploymentStatusTransitionGracePeriodExceeded),
315+
Equal(rayv1.SubmissionFailed),
316+
)))
318317
// Cleanup
319318
err = test.Client().Ray().RayV1().RayJobs(namespace.Name).Delete(test.Ctx(), rayJob.Name, metav1.DeleteOptions{})
320319
g.Expect(err).NotTo(HaveOccurred())

0 commit comments

Comments
 (0)