Fix swallowed errors in statefulset tests

parent 078a3b65
...@@ -474,6 +474,9 @@ func TestStatefulSetControl_getSetRevisions(t *testing.T) { ...@@ -474,6 +474,9 @@ func TestStatefulSetControl_getSetRevisions(t *testing.T) {
t.Fatal(err) t.Fatal(err)
} }
current, update, _, err := ssc.getStatefulSetRevisions(test.set, revisions) current, update, _, err := ssc.getStatefulSetRevisions(test.set, revisions)
if err != nil {
t.Fatalf("error getting statefulset revisions:%v", err)
}
revisions, err = ssc.ListRevisions(test.set) revisions, err = ssc.ListRevisions(test.set)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
......
...@@ -615,6 +615,9 @@ func scaleUpStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetControl ...@@ -615,6 +615,9 @@ func scaleUpStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetControl
} }
for set.Status.ReadyReplicas < *set.Spec.Replicas { for set.Status.ReadyReplicas < *set.Spec.Replicas {
pods, err := spc.podsLister.Pods(set.Namespace).List(selector) pods, err := spc.podsLister.Pods(set.Namespace).List(selector)
if err != nil {
return err
}
ord := len(pods) - 1 ord := len(pods) - 1
pod := getPodAtOrdinal(pods, ord) pod := getPodAtOrdinal(pods, ord)
if pods, err = spc.setPodPending(set, ord); err != nil { if pods, err = spc.setPodPending(set, ord); err != nil {
...@@ -669,6 +672,9 @@ func scaleDownStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetContr ...@@ -669,6 +672,9 @@ func scaleDownStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetContr
ssc.enqueueStatefulSet(set) ssc.enqueueStatefulSet(set)
fakeWorker(ssc) fakeWorker(ssc)
pods, err = spc.addTerminatingPod(set, ord) pods, err = spc.addTerminatingPod(set, ord)
if err != nil {
return err
}
pod = getPodAtOrdinal(pods, ord) pod = getPodAtOrdinal(pods, ord)
ssc.updatePod(&prev, pod) ssc.updatePod(&prev, pod)
fakeWorker(ssc) fakeWorker(ssc)
...@@ -677,8 +683,15 @@ func scaleDownStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetContr ...@@ -677,8 +683,15 @@ func scaleDownStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetContr
fakeWorker(ssc) fakeWorker(ssc)
for set.Status.Replicas > *set.Spec.Replicas { for set.Status.Replicas > *set.Spec.Replicas {
pods, err = spc.podsLister.Pods(set.Namespace).List(selector) pods, err = spc.podsLister.Pods(set.Namespace).List(selector)
if err != nil {
return err
}
ord := len(pods) ord := len(pods)
pods, err = spc.addTerminatingPod(set, ord) pods, err = spc.addTerminatingPod(set, ord)
if err != nil {
return err
}
pod = getPodAtOrdinal(pods, ord) pod = getPodAtOrdinal(pods, ord)
ssc.updatePod(&prev, pod) ssc.updatePod(&prev, pod)
fakeWorker(ssc) fakeWorker(ssc)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment