diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go index 2b7cda8dd..5a77e658b 100644 --- a/pkg/cluster/sync.go +++ b/pkg/cluster/sync.go @@ -128,11 +128,6 @@ func (c *Cluster) syncService(role PostgresRole) error { } c.Services[role] = nil - // Service does not exist - if role == Replica && !c.Spec.ReplicaLoadBalancer { - return nil - } - c.logger.Infof("could not find the cluster's %s service", role) if svc, err := c.createService(role); err != nil { @@ -168,10 +163,6 @@ func (c *Cluster) syncEndpoint(role PostgresRole) error { } c.Endpoints[role] = nil - if role == Replica && !c.Spec.ReplicaLoadBalancer { - return nil - } - c.logger.Infof("could not find the cluster's %s endpoint", role) if ep, err := c.createEndpoint(role); err != nil {