in pkg/provider/eks/eks.go [468:485]
func (c *EKS) AllNodeGroupsRunning(*kingpin.ParseContext) error {
req := &eksCluster{}
for _, deployment := range c.eksResources {
if err := yamlGo.UnmarshalStrict(deployment.Content, req); err != nil {
return fmt.Errorf("Error parsing the cluster deployment file %s:%v", deployment.FileName, err)
}
for _, nodegroup := range req.NodeGroups {
isRunning, err := c.nodeGroupCreated(*nodegroup.NodegroupName, *req.Cluster.Name)
if err != nil {
return fmt.Errorf("error fetching nodegroup info")
}
if !isRunning {
return fmt.Errorf("nodepool not running name: %v", *nodegroup.NodegroupName)
}
}
}
return nil
}