From 4db5bd13d12f705e5345c5f1f428c84802b20d50 Mon Sep 17 00:00:00 2001 From: Murat Kabilov Date: Mon, 4 Sep 2017 18:48:03 +0200 Subject: [PATCH] delete cluster key from the clusters list only when delete procedure is finished --- pkg/controller/postgresql.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/controller/postgresql.go b/pkg/controller/postgresql.go index 2c446f0b8..876271d0e 100644 --- a/pkg/controller/postgresql.go +++ b/pkg/controller/postgresql.go @@ -200,6 +200,11 @@ func (c *Controller) processEvent(event spec.ClusterEvent) { lg.Infoln("deletion of the cluster started") teamName := strings.ToLower(cl.Spec.TeamID) + + if err := cl.Delete(); err != nil { + lg.Errorf("could not delete cluster: %v", err) + } + func() { defer c.clustersMu.Unlock() c.clustersMu.Lock() @@ -216,11 +221,6 @@ func (c *Controller) processEvent(event spec.ClusterEvent) { } }() - if err := cl.Delete(); err != nil { - lg.Errorf("could not delete cluster: %v", err) - return - } - lg.Infof("cluster has been deleted") case spec.EventSync: lg.Infof("syncing of the cluster started")