From 94e8bdedad8fbdd0751bc821c591abb422757e71 Mon Sep 17 00:00:00 2001 From: Simon Pasquier Date: Fri, 30 Jan 2026 15:30:11 +0100 Subject: [PATCH] Use new CreateStatefulSetOrPatchLabels() function in controllers Signed-off-by: Simon Pasquier --- pkg/alertmanager/operator.go | 2 +- pkg/prometheus/agent/operator.go | 2 +- pkg/prometheus/server/operator.go | 2 +- pkg/thanos/operator.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/alertmanager/operator.go b/pkg/alertmanager/operator.go index 128ae46fe..e599d57c4 100644 --- a/pkg/alertmanager/operator.go +++ b/pkg/alertmanager/operator.go @@ -679,7 +679,7 @@ func (c *Operator) sync(ctx context.Context, key string) error { if shouldCreate { logger.Debug("no current statefulset found") logger.Debug("creating statefulset") - if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil { + if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil { return fmt.Errorf("creating statefulset failed: %w", err) } return nil diff --git a/pkg/prometheus/agent/operator.go b/pkg/prometheus/agent/operator.go index ad2f0194b..7c8a00f62 100644 --- a/pkg/prometheus/agent/operator.go +++ b/pkg/prometheus/agent/operator.go @@ -838,7 +838,7 @@ func (c *Operator) syncStatefulSet(ctx context.Context, key string, p *monitorin if notFound { logger.Debug("creating statefulset") - if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil { + if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil { return fmt.Errorf("creating statefulset failed: %w", err) } continue diff --git a/pkg/prometheus/server/operator.go b/pkg/prometheus/server/operator.go index 97702bb60..7dcc70a2e 100644 --- a/pkg/prometheus/server/operator.go +++ b/pkg/prometheus/server/operator.go @@ -993,7 +993,7 @@ func (c *Operator) sync(ctx context.Context, key string) error { if notFound { logger.Debug("creating statefulset") - if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil { + if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil { return fmt.Errorf("creating statefulset failed: %w", err) } continue diff --git a/pkg/thanos/operator.go b/pkg/thanos/operator.go index c51ad2086..e650fa3fa 100644 --- a/pkg/thanos/operator.go +++ b/pkg/thanos/operator.go @@ -589,7 +589,7 @@ func (o *Operator) sync(ctx context.Context, key string) error { ssetClient := o.kclient.AppsV1().StatefulSets(tr.Namespace) if shouldCreate { logger.Debug("creating statefulset") - if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil { + if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil { return fmt.Errorf("creating thanos statefulset failed: %w", err) }