K8SPG-493: disable scheduled backups when .spec.pause: true

https://perconadev.atlassian.net/browse/K8SPG-493
percona · Jan 19, 2024 · 62dd837 · 62dd837
1 parent 8c8c59f
commit 62dd837
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/percona/controller/pgcluster/controller.go b/percona/controller/pgcluster/controller.go
@@ -66,6 +66,9 @@ func (r *PGClusterReconciler) SetupWithManager(mgr manager.Manager) error {
 	if err := r.CrunchyController.Watch(source.Kind(mgr.GetCache(), &batchv1.Job{}), r.watchBackupJobs()); err != nil {
 		return errors.Wrap(err, "unable to watch jobs")
 	}
+	if err := r.CrunchyController.Watch(source.Kind(mgr.GetCache(), &v2.PerconaPGBackup{}), r.watchPGBackups()); err != nil {
+		return errors.Wrap(err, "unable to watch pg-backups")
+	}
 
 	return builder.ControllerManagedBy(mgr).
 		For(&v2.PerconaPGCluster{}).

diff --git a/percona/controller/pgcluster/schedule.go b/percona/controller/pgcluster/schedule.go
@@ -101,6 +101,10 @@ func (r *PGClusterReconciler) createScheduledBackup(log logr.Logger, backupName,
 		}
 		return err
 	}
+	if cr.Status.State != v2.AppStateReady {
+		log.Info("Cluster is not ready. Can't start scheduled backup")
+		return nil
+	}
 
 	pb := &v2.PerconaPGBackup{
 		ObjectMeta: metav1.ObjectMeta{