Skip to content

Commit 524169f

Browse files
authored
Merge pull request kubernetes#77005 from k-toyoda-pi/e2e_add_check_pod_in_job
[e2e] add pod status check after job completes in job test
2 parents b9bde60 + 8afecb8 commit 524169f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

test/e2e/apps/job.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,14 @@ var _ = SIGDescribe("Job", func() {
4747
ginkgo.By("Ensuring job reaches completions")
4848
err = jobutil.WaitForJobComplete(f.ClientSet, f.Namespace.Name, job.Name, completions)
4949
framework.ExpectNoError(err, "failed to ensure job completion in namespace: %s", f.Namespace.Name)
50+
51+
ginkgo.By("Ensuring pods for job exist")
52+
pods, err := jobutil.GetJobPods(f.ClientSet, f.Namespace.Name, job.Name)
53+
framework.ExpectNoError(err, "failed to get pod list for job in namespace: %s", f.Namespace.Name)
54+
gomega.Expect(len(pods.Items)).To(gomega.Equal(int(completions)), "failed to ensure sufficient pod for job: got %d, want %d", len(pods.Items), completions)
55+
for _, pod := range pods.Items {
56+
gomega.Expect(pod.Status.Phase).To(gomega.Equal(v1.PodSucceeded), "failed to ensure pod status: pod %s status %s", pod.Name, pod.Status.Phase)
57+
}
5058
})
5159

5260
// Pods sometimes fail, but eventually succeed.

0 commit comments

Comments
 (0)