diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go index 017168063..f490ece81 100644 --- a/pkg/cluster/sync.go +++ b/pkg/cluster/sync.go @@ -4,7 +4,7 @@ import ( "fmt" batchv1beta1 "k8s.io/api/batch/v1beta1" - "k8s.io/api/core/v1" + v1 "k8s.io/api/core/v1" policybeta1 "k8s.io/api/policy/v1beta1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -539,6 +539,11 @@ func (c *Cluster) syncLogicalBackupJob() error { ) c.setProcessName("syncing the logical backup job") + // operator pod at startup syncs all clusters, logicalBackupJob will be nil at this point + if (c.Postgresql.Spec.EnableLogicalBackup == true) && (c.logicalBackupJob == nil) { + c.logicalBackupJob, err = c.generateLogicalBackupJob() + } + if job, err = c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Get(c.logicalBackupJob.Name, metav1.GetOptions{}); err == nil { desiredJob, err = c.generateLogicalBackupJob()