From 42921496e95ce54d83d2d45795c0a6412e25761d Mon Sep 17 00:00:00 2001 From: Natalia Marukovich Date: Thu, 26 Mar 2026 16:39:03 +0100 Subject: [PATCH] K8SPG-740 fix --- percona/controller/pgcluster/backup.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/percona/controller/pgcluster/backup.go b/percona/controller/pgcluster/backup.go index 53c33cd06..388d0bcfc 100644 --- a/percona/controller/pgcluster/backup.go +++ b/percona/controller/pgcluster/backup.go @@ -2,6 +2,7 @@ package pgcluster import ( "context" + "strings" "github.com/pkg/errors" batchv1 "k8s.io/api/batch/v1" @@ -71,7 +72,8 @@ func (r *PGClusterReconciler) cleanupOutdatedBackups(ctx context.Context, cr *v2 readyPod, err := controller.GetReadyInstancePod(ctx, r.Client, cr.Name, cr.Namespace) if err != nil { - return errors.Wrap(err, "get ready instance pod") + log.Info("No ready instance pod found, skipping backup cleanup", "repo", repo.Name, "reason", err.Error()) + continue } info, err = pgbackrest.GetInfo(ctx, readyPod, repo.Name) if err != nil { @@ -83,6 +85,10 @@ func (r *PGClusterReconciler) cleanupOutdatedBackups(ctx context.Context, cr *v2 log.Info("pgBackRest stanza not yet created, skipping backup cleanup", "repo", repo.Name) continue } + if strings.Contains(err.Error(), "container not found") { + log.Info("Container not ready, skipping backup cleanup", "repo", repo.Name, "reason", err.Error()) + continue + } return errors.Wrap(err, "get pgBackRest info") }