Skip to content

Commit 37af2e4

Browse files
committed
improve disableRestore
1 parent 0e32ee7 commit 37af2e4

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

percona/controller/pgrestore/controller.go

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -245,10 +245,25 @@ func disableRestore(ctx context.Context, c client.Client, pg *v2.PerconaPGCluste
245245
fvar := false
246246
pg.Spec.Backups.PGBackRest.Restore.Enabled = &fvar
247247

248+
delete(pg.Annotations, naming.LabelPGBackRestRestore)
249+
248250
if err := c.Patch(ctx, pg, client.MergeFrom(orig)); err != nil {
249251
return errors.Wrap(err, "patch PGCluster")
250252
}
251253

254+
postgresCluster := new(v1beta1.PostgresCluster)
255+
if err := c.Get(ctx, client.ObjectKeyFromObject(pg), postgresCluster); err != nil {
256+
return errors.Wrap(err, "get PostgresCluster")
257+
}
258+
259+
origPostgres := postgresCluster.DeepCopy()
260+
261+
postgresCluster.Status.PGBackRest.Restore = new(v1beta1.PGBackRestJobStatus)
262+
263+
if err := c.Status().Patch(ctx, postgresCluster, client.MergeFrom(origPostgres)); err != nil {
264+
return errors.Wrap(err, "patch PGCluster")
265+
}
266+
252267
return nil
253268
}
254269

0 commit comments

Comments
 (0)