Wait for new server version in integration test (eksctl-io#2644)

integration/tests/managed/managed_nodegroup_test.go

@@ -25,6 +25,11 @@ import (
 	"k8s.io/client-go/tools/clientcmd"
 )
 
+const (
+	k8sUpdatePollInterval = "2s"
+	k8sUpdatePollTimeout  = "3m"
+)
+
 var params *tests.Params
 
 func init() {
@@ -246,10 +251,11 @@ var _ = Describe("(Integration) Create Managed Nodegroups", func() {
 
 				clientset, err := kubernetes.NewForConfig(config)
 				Expect(err).ToNot(HaveOccurred())
-
-				serverVersion, err := clientset.ServerVersion()
-				Expect(err).ToNot(HaveOccurred())
-				Expect(fmt.Sprintf("%s.%s", serverVersion.Major, strings.TrimSuffix(serverVersion.Minor, "+"))).To(Equal(nextVersion))
+				Eventually(func() string {
+					serverVersion, err := clientset.ServerVersion()
+					Expect(err).ToNot(HaveOccurred())
+					return fmt.Sprintf("%s.%s", serverVersion.Major, strings.TrimSuffix(serverVersion.Minor, "+"))
+				}, k8sUpdatePollTimeout, k8sUpdatePollInterval).Should(Equal(nextVersion))
 
 				By(fmt.Sprintf("upgrading nodegroup %s to Kubernetes version %s", initialNodeGroup, nextVersion))
 				cmd = params.EksctlUpgradeCmd.WithArgs(