Skip to content

Commit cadeca5

Browse files
committed
refactor: retry if not all nodes are attached to the cluster
1 parent b125c7f commit cadeca5

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

backend/internal/core/workflows/deployer_activities.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -899,6 +899,10 @@ func VerifyClusterReadyStep() ewf.StepFn {
899899
return fmt.Errorf("failed to get nodes of cluster %s: %w", cluster.Name, err)
900900
}
901901

902+
if len(nodes) != len(cluster.Nodes) {
903+
return fmt.Errorf("not all nodes joined cluster %s yet: %d/%d nodes joined", cluster.Name, len(nodes), len(cluster.Nodes))
904+
}
905+
902906
// Create map of k8s node health by node name (lowercase for matching)
903907
k8sNodeHealth := make(map[string]bool)
904908
for _, n := range nodes {

0 commit comments

Comments
 (0)