eks: increase list nodes batch limit

Signed-off-by: Gyuho Lee <leegyuho@amazon.com>
aws · Jul 10, 2020 · 7d36a80 · 7d36a80
1 parent d924eb6
commit 7d36a80
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/eks/irsa-fargate/irsa-fargate.go b/eks/irsa-fargate/irsa-fargate.go
@@ -1103,7 +1103,7 @@ func (ts *tester) checkNodeReadiness() error {
 
 	desired := 1
 
-	nodes, err := ts.cfg.K8SClient.ListNodes(150, 5*time.Second)
+	nodes, err := ts.cfg.K8SClient.ListNodes(1000, 5*time.Second)
 	if err != nil {
 		ts.cfg.Logger.Warn("get nodes failed", zap.Error(err))
 		return err

diff --git a/eks/mng/version-upgrade/version-upgrade.go b/eks/mng/version-upgrade/version-upgrade.go
@@ -151,7 +151,7 @@ func (ts *tester) Upgrade(mngName string) (err error) {
 		wait.WithQueryFunc(func() {
 			fmt.Fprintf(ts.cfg.LogWriter, "\n")
 			ts.cfg.Logger.Info("listing nodes while polling mng update status", zap.String("mng-name", mngName))
-			nodes, err := ts.cfg.K8SClient.ListNodes(150, 5*time.Second)
+			nodes, err := ts.cfg.K8SClient.ListNodes(1000, 5*time.Second)
 			if err != nil {
 				ts.cfg.Logger.Warn("failed to list nodes while polling mng update status", zap.Error(err))
 				return

diff --git a/eks/mng/wait/wait.go b/eks/mng/wait/wait.go
@@ -204,7 +204,7 @@ func (ts *tester) waitForNodes(mngName string, retriesLeft int) error {
 		case <-time.After(5 * time.Second):
 		}
 
-		nodes, err := ts.cfg.K8SClient.ListNodes(150, 5*time.Second)
+		nodes, err := ts.cfg.K8SClient.ListNodes(1000, 5*time.Second)
 		if err != nil {
 			ts.cfg.Logger.Warn("get nodes failed", zap.Error(err))
 			continue

diff --git a/eks/ng/wait/wait.go b/eks/ng/wait/wait.go
@@ -166,7 +166,7 @@ func (ts *tester) waitForNodes(asgName string, retriesLeft int) error {
 		case <-time.After(5 * time.Second):
 		}
 
-		nodes, err := ts.cfg.K8SClient.ListNodes(150, 5*time.Second)
+		nodes, err := ts.cfg.K8SClient.ListNodes(1000, 5*time.Second)
 		if err != nil {
 			ts.cfg.Logger.Warn("get nodes failed", zap.Error(err))
 			continue