From fe1d1b2decfdcebb3dfe22b8f436eb2a8d57a406 Mon Sep 17 00:00:00 2001 From: Sergey Dudoladov Date: Tue, 16 Apr 2019 11:56:27 +0200 Subject: [PATCH] add special case for Sync --- pkg/cluster/sync.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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()