diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go index a6644b868..e8eed15cc 100644 --- a/pkg/cluster/cluster.go +++ b/pkg/cluster/cluster.go @@ -287,7 +287,7 @@ func (c *Cluster) Create() error { c.logger.Infof("pods are ready") // create database objects unless we are running without pods or disabled that feature explicitly - if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&c.Spec) <= 0) { + if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&c.Spec) <= 0 || c.Spec.StandbyCluster != nil) { if err = c.createRoles(); err != nil { return fmt.Errorf("could not create users: %v", err) } @@ -626,7 +626,7 @@ func (c *Cluster) Update(oldSpec, newSpec *acidv1.Postgresql) error { }() // Roles and Databases - if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&c.Spec) <= 0) { + if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&c.Spec) <= 0 || c.Spec.StandbyCluster != nil) { c.logger.Debugf("syncing roles") if err := c.syncRoles(); err != nil { c.logger.Errorf("could not sync roles: %v", err) diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go index 6654242eb..dd55cd04c 100644 --- a/pkg/cluster/sync.go +++ b/pkg/cluster/sync.go @@ -90,7 +90,7 @@ func (c *Cluster) Sync(newSpec *acidv1.Postgresql) error { } // create database objects unless we are running without pods or disabled that feature explicitly - if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&newSpec.Spec) <= 0) { + if !(c.databaseAccessDisabled() || c.getNumberOfInstances(&newSpec.Spec) <= 0 || c.Spec.StandbyCluster != nil) { c.logger.Debugf("syncing roles") if err = c.syncRoles(); err != nil { err = fmt.Errorf("could not sync roles: %v", err) @@ -428,10 +428,6 @@ func (c *Cluster) syncSecrets() error { func (c *Cluster) syncRoles() (err error) { c.setProcessName("syncing roles") - if c.Spec.StandbyCluster != nil { - c.logger.Info("no need to sync roles for standby cluster") - return nil - } var ( dbUsers spec.PgUserMap userNames []string