diff --git a/pkg/cluster/pod.go b/pkg/cluster/pod.go index a1cc0ffd4c870b640d6394b555ac80c27a07e06c..229648dd1d68b5deb9edf544d409ed551c5cebe9 100644 --- a/pkg/cluster/pod.go +++ b/pkg/cluster/pod.go @@ -304,7 +304,7 @@ func (c *Cluster) MigrateMasterPod(podName spec.NamespacedName) error { } masterCandidateName := util.NameFromMeta(masterCandidatePod.ObjectMeta) - _ = retryutil.Retry(1*time.Minute, 5*time.Minute, + err = retryutil.Retry(1*time.Minute, 5*time.Minute, func() (bool, error) { err := c.Switchover(oldMaster, masterCandidateName) if err != nil { @@ -315,6 +315,10 @@ func (c *Cluster) MigrateMasterPod(podName spec.NamespacedName) error { }, ) + if err != nil { + return fmt.Errorf("could not migrate master pod: %v", err) + } + return nil }