From bbb424dc2d8959c0759392bfe9ee4f3236856422 Mon Sep 17 00:00:00 2001 From: Felix Kunde Date: Tue, 12 Nov 2019 17:45:10 +0100 Subject: [PATCH] nullify service and endpoint before recreation --- pkg/cluster/resources.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pkg/cluster/resources.go b/pkg/cluster/resources.go index ebd4990ef..180c19e20 100644 --- a/pkg/cluster/resources.go +++ b/pkg/cluster/resources.go @@ -380,8 +380,6 @@ func (c *Cluster) updateService(role PostgresRole, newService *v1.Service) error return fmt.Errorf("could not delete service %q: %v", serviceName, err) } - // make sure we clear the stored service status if the subsequent create fails. - c.Services[role] = nil // wait until the service is truly deleted c.logger.Debugf("waiting for service to be deleted") @@ -395,7 +393,8 @@ func (c *Cluster) updateService(role PostgresRole, newService *v1.Service) error return fmt.Errorf("could not delete service %q: %v", serviceName, err) } - // make sure we clear the stored endpoint status if the subsequent create fails. + // make sure we clear the stored service and endpoint status if the subsequent create fails. + c.Services[role] = nil c.Endpoints[role] = nil if role == Master { // create the new endpoint using the addresses obtained from the previous one