From 427a924983c4367cd976f51e2ddddc499a3e4b93 Mon Sep 17 00:00:00 2001 From: Brendan Burns Date: Fri, 2 Oct 2015 21:11:04 -0700 Subject: [PATCH] Disable jobs tests in GKE --- test/e2e/job.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/test/e2e/job.go b/test/e2e/job.go index 339e79710bd..0b20a61199f 100644 --- a/test/e2e/job.go +++ b/test/e2e/job.go @@ -40,6 +40,7 @@ const ( jobSelectorKey = "job" ) +// TODO: Activate these tests for GKE when we support experimental APIs there. var _ = Describe("Job", func() { f := NewFramework("job") parallelism := 2 @@ -48,6 +49,7 @@ var _ = Describe("Job", func() { // Simplest case: all pods succeed promptly It("should run a job to completion when tasks succeed", func() { + SkipIfProviderIs("gke") By("Creating a job") job := newTestJob("succeed", "all-succeed", api.RestartPolicyNever, parallelism, completions) job, err := createJob(f.Client, f.Namespace.Name, job) @@ -60,6 +62,7 @@ var _ = Describe("Job", func() { // Pods sometimes fail, but eventually succeed. It("should run a job to completion when tasks sometimes fail and are locally restarted", func() { + SkipIfProviderIs("gke") By("Creating a job") // 50% chance of container success, local restarts. job := newTestJob("randomlySucceedOrFail", "rand-local", api.RestartPolicyOnFailure, parallelism, completions) @@ -73,6 +76,7 @@ var _ = Describe("Job", func() { // Pods sometimes fail, but eventually succeed, after pod restarts It("should run a job to completion when tasks sometimes fail and are not locally restarted", func() { + SkipIfProviderIs("gke") By("Creating a job") // 50% chance of container success, local restarts. job := newTestJob("randomlySucceedOrFail", "rand-non-local", api.RestartPolicyNever, parallelism, completions) @@ -85,6 +89,7 @@ var _ = Describe("Job", func() { }) It("should keep restarting failed pods", func() { + SkipIfProviderIs("gke") By("Creating a job") job := newTestJob("fail", "all-fail", api.RestartPolicyNever, parallelism, completions) job, err := createJob(f.Client, f.Namespace.Name, job) @@ -101,6 +106,7 @@ var _ = Describe("Job", func() { }) It("should scale a job up", func() { + SkipIfProviderIs("gke") startParallelism := 1 endParallelism := 2 By("Creating a job") @@ -126,6 +132,7 @@ var _ = Describe("Job", func() { }) It("should scale a job down", func() { + SkipIfProviderIs("gke") startParallelism := 2 endParallelism := 1 By("Creating a job") @@ -151,6 +158,7 @@ var _ = Describe("Job", func() { }) It("should stop a job", func() { + SkipIfProviderIs("gke") By("Creating a job") job := newTestJob("notTerminate", "foo", api.RestartPolicyNever, parallelism, completions) job, err := createJob(f.Client, f.Namespace.Name, job)