@@ -72,7 +72,7 @@ func verifyCheckpoint(c *Cluster, namespace, daemonsetName string, shouldExist,
7272
7373 return nil
7474 }
75- return retry (20 , 10 * time .Second , checkpointed )
75+ return retry (60 , 10 * time .Second , checkpointed )
7676}
7777
7878func verifyPod (c * Cluster , daemonsetName string , shouldRun bool ) error {
@@ -90,7 +90,7 @@ func verifyPod(c *Cluster, daemonsetName string, shouldRun bool) error {
9090 }
9191 return nil
9292 }
93- return retry (20 , 10 * time .Second , checkpointsRunning )
93+ return retry (60 , 10 * time .Second , checkpointsRunning )
9494}
9595
9696func isNodeReady (n * Node ) bool {
@@ -131,7 +131,7 @@ func waitCluster(t *testing.T) *Cluster {
131131 return nil
132132 }
133133
134- if err := retry (20 , 10 * time .Second , f ); err != nil {
134+ if err := retry (60 , 10 * time .Second , f ); err != nil {
135135 t .Fatalf ("Failed to wait cluster: %v" , err )
136136 }
137137 return c
@@ -144,7 +144,7 @@ func waitForCheckpointDeactivation(t *testing.T) {
144144 t .Log ("Waiting 120 seconds for checkpoints to deactivate." )
145145 time .Sleep (120 * time .Second )
146146 successes := 0
147- if err := retry (20 , 3 * time .Second , func () error {
147+ if err := retry (60 , 3 * time .Second , func () error {
148148 _ , err := client .Discovery ().ServerVersion ()
149149 if err != nil {
150150 successes = 0
@@ -222,8 +222,8 @@ func TestCheckpointerUnscheduleCheckpointer(t *testing.T) {
222222 }
223223
224224 // Delete the pod checkpointer on the worker node by updating the daemonset.
225- patch = `[{"op": "replace", "path": "/spec/template/spec/ nodeSelector", "value": {"node-role.kubernetes.io/master":""}}] `
226- _ , err = client .ExtensionsV1beta1 ().DaemonSets ("kube-system" ).Patch ("pod-checkpointer" , types .JSONPatchType , []byte (patch ))
225+ patch = `{"spec":{"template":{"spec":{" nodeSelector": {"node-role.kubernetes.io/master":""}}}}} `
226+ _ , err = client .ExtensionsV1beta1 ().DaemonSets ("kube-system" ).Patch ("pod-checkpointer" , types .MergePatchType , []byte (patch ))
227227 if err != nil {
228228 t .Fatalf ("Failed to patch checkpointer: %v" , err )
229229 }
@@ -352,8 +352,8 @@ func TestCheckpointerUnscheduleParent(t *testing.T) {
352352 }
353353
354354 // Delete test pod on the workers.
355- patch = `[{"op": "replace", "path": "/spec/template/spec/ nodeSelector", "value": {"node-role.kubernetes.io/master":""}}] `
356- _ , err = client .ExtensionsV1beta1 ().DaemonSets (testNS ).Patch ("nginx-daemonset" , types .JSONPatchType , []byte (patch ))
355+ patch = `{"spec":{"template":{"spec":{" nodeSelector": {"node-role.kubernetes.io/master":""}}}}} `
356+ _ , err = client .ExtensionsV1beta1 ().DaemonSets (testNS ).Patch ("nginx-daemonset" , types .MergePatchType , []byte (patch ))
357357 if err != nil {
358358 t .Fatalf ("unable to patch daemonset: %v" , err )
359359 }
0 commit comments