From 8afecb8c306bb0587c820d027069f4e802fa5693 Mon Sep 17 00:00:00 2001 From: toyoda Date: Wed, 24 Apr 2019 20:31:17 +0900 Subject: [PATCH] add pod status check after job completes in job e2e test --- test/e2e/apps/job.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/test/e2e/apps/job.go b/test/e2e/apps/job.go index 565147f4e2..28e75cff1b 100644 --- a/test/e2e/apps/job.go +++ b/test/e2e/apps/job.go @@ -47,6 +47,14 @@ var _ = SIGDescribe("Job", func() { ginkgo.By("Ensuring job reaches completions") err = jobutil.WaitForJobComplete(f.ClientSet, f.Namespace.Name, job.Name, completions) framework.ExpectNoError(err, "failed to ensure job completion in namespace: %s", f.Namespace.Name) + + ginkgo.By("Ensuring pods for job exist") + pods, err := jobutil.GetJobPods(f.ClientSet, f.Namespace.Name, job.Name) + framework.ExpectNoError(err, "failed to get pod list for job in namespace: %s", f.Namespace.Name) + 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) + for _, pod := range pods.Items { + gomega.Expect(pod.Status.Phase).To(gomega.Equal(v1.PodSucceeded), "failed to ensure pod status: pod %s status %s", pod.Name, pod.Status.Phase) + } }) // Pods sometimes fail, but eventually succeed.