diff --git a/test/integration/scheduler_test.go b/test/integration/scheduler_test.go index 48b24847695..a6bf5934006 100644 --- a/test/integration/scheduler_test.go +++ b/test/integration/scheduler_test.go @@ -37,6 +37,7 @@ import ( "k8s.io/kubernetes/pkg/client/record" client "k8s.io/kubernetes/pkg/client/unversioned" "k8s.io/kubernetes/pkg/master" + "k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util/wait" "k8s.io/kubernetes/plugin/pkg/admission/admit" "k8s.io/kubernetes/plugin/pkg/scheduler" @@ -253,7 +254,7 @@ func DoTestUnschedulableNodes(t *testing.T, restClient *client.Client, nodeStore } // There are no schedulable nodes - the pod shouldn't be scheduled. - err = wait.Poll(time.Second, time.Second*10, podScheduled(restClient, myPod.Namespace, myPod.Name)) + err = wait.Poll(time.Second, util.ForeverTestTimeout, podScheduled(restClient, myPod.Namespace, myPod.Name)) if err == nil { t.Errorf("Pod scheduled successfully on unschedulable nodes") } @@ -271,7 +272,7 @@ func DoTestUnschedulableNodes(t *testing.T, restClient *client.Client, nodeStore mod.makeSchedulable(t, schedNode, nodeStore, restClient) // Wait until the pod is scheduled. - err = wait.Poll(time.Second, time.Second*10, podScheduled(restClient, myPod.Namespace, myPod.Name)) + err = wait.Poll(time.Second, util.ForeverTestTimeout, podScheduled(restClient, myPod.Namespace, myPod.Name)) if err != nil { t.Errorf("Test %d: failed to schedule a pod: %v", i, err) } else {