func (t *JobUpgradeTest) Setup(f *framework.Framework) {
	t.namespace = f.Namespace.Name

	ginkgo.By("Creating a job")
	t.job = e2ejob.NewTestJob("notTerminate", "foo", v1.RestartPolicyOnFailure, 2, 2, nil, 6)
	job, err := e2ejob.CreateJob(f.ClientSet, t.namespace, t.job)
	t.job = job
	framework.ExpectNoError(err)

	ginkgo.By("Ensuring active pods == parallelism")
	err = e2ejob.WaitForAllJobPodsRunning(f.ClientSet, t.namespace, job.Name, 2)
	framework.ExpectNoError(err)
}
// Setup starts a Job with a parallelism of 2 and 2 completions running.
Setup starts a Job with a parallelism of 2 and 2 completions running.
// Setup starts a Job with a parallelism of 2 and 2 completions running .
func (t *JobUpgradeTest) Setup(f *framework.Framework) {
	t.namespace = f.Namespace.Name
	ginkgo.By("Creating a job")
	t.job = e2ejob.NewTestJob("notTerminate", "foo", v1.RestartPolicyOnFailure, 2, 2, nil, 6)
	job, err := e2ejob.CreateJob(f.ClientSet, t.namespace, t.job)
	t.job = job
	framework.ExpectNoError(err)
	ginkgo.By("Ensuring active pods == parallelism")
	err = e2ejob.WaitForAllJobPodsRunning(f.ClientSet, t.namespace, job.Name, 2)
	framework.ExpectNoError(err)
}
func ( t * JobUpgradeTest ) Setup ( f * framework . Framework ) { t . namespace = f . Namespace . Name ginkgo . By ( " " ) t . job = e2ejob . NewTestJob ( " " , " " , v1 . RestartPolicyOnFailure , 2 , 2 , nil , 6 ) job , err := e2ejob . CreateJob ( f . ClientSet , t . namespace , t . job ) t . job = job framework . ExpectNoError ( err ) ginkgo . By ( " " ) err = e2ejob . WaitForAllJobPodsRunning ( f . ClientSet , t . namespace , job . Name , 2 ) framework . ExpectNoError ( err ) }
Setup starts a Job with a parallelism of 2 and 2 completions running.
Setup starts a Job with a parallelism of 2 and 2 completions running .