Added handling of failed states when waiting for cluster status.

couchbaselabs · Sep 10, 2024 · d80ee90 · d80ee90
1 parent d5b21e8
commit d80ee90
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/utils/capellacontrol/manager.go b/utils/capellacontrol/manager.go
@@ -3,6 +3,7 @@ package capellacontrol
 import (
 	"context"
 	"fmt"
+	"strings"
 	"time"
 
 	"github.com/pkg/errors"
@@ -71,6 +72,10 @@ func (m *Manager) WaitForClusterState(
 			return fmt.Errorf("cluster disappeared during wait for '%s' state", desiredState)
 		}
 
+		if strings.Contains(clusterStatus, "failed") {
+			return fmt.Errorf("cancelling as cluster is in a failed state ('%s')", clusterStatus)
+		}
+
 		m.Logger.Info("waiting for cluster status...",
 			zap.String("current", clusterStatus),
 			zap.String("desired", desiredState))