From fd53b11b3c635b1defb36a7406ed30c5ad201025 Mon Sep 17 00:00:00 2001 From: Felix Kunde Date: Fri, 9 Apr 2021 11:26:36 +0200 Subject: [PATCH] remove update annotation function for statefulset --- pkg/cluster/resources.go | 26 -------------------------- 1 file changed, 26 deletions(-) diff --git a/pkg/cluster/resources.go b/pkg/cluster/resources.go index ed8b4099c..48b17f532 100644 --- a/pkg/cluster/resources.go +++ b/pkg/cluster/resources.go @@ -147,25 +147,6 @@ func (c *Cluster) preScaleDown(newStatefulSet *appsv1.StatefulSet) error { return nil } -func (c *Cluster) updateStatefulSetAnnotations(annotations map[string]string) (*appsv1.StatefulSet, error) { - c.logger.Debugf("patching statefulset annotations") - patchData, err := metaAnnotationsPatch(annotations) - if err != nil { - return nil, fmt.Errorf("could not form patch for the statefulset metadata: %v", err) - } - result, err := c.KubeClient.StatefulSets(c.Statefulset.Namespace).Patch( - context.TODO(), - c.Statefulset.Name, - types.MergePatchType, - []byte(patchData), - metav1.PatchOptions{}, - "") - if err != nil { - return nil, fmt.Errorf("could not patch statefulset annotations %q: %v", patchData, err) - } - return result, nil -} - func (c *Cluster) updateStatefulSet(newStatefulSet *appsv1.StatefulSet) error { c.setProcessName("updating statefulset") if c.Statefulset == nil { @@ -197,13 +178,6 @@ func (c *Cluster) updateStatefulSet(newStatefulSet *appsv1.StatefulSet) error { return fmt.Errorf("could not patch statefulset spec %q: %v", statefulSetName, err) } - if newStatefulSet.Annotations != nil { - statefulSet, err = c.updateStatefulSetAnnotations(newStatefulSet.Annotations) - if err != nil { - return err - } - } - c.Statefulset = statefulSet return nil