Check nodegroup was indeed upgraded

integration/tests/update/update_cluster_test.go

@@ -105,9 +105,9 @@ var _ = BeforeSuite(func() {
 	)
 	Expect(cmd).To(RunSuccessfully())
 })
-var _ = Describe("(Integration) Update addons", func() {
+var _ = Describe("(Integration) Upgrading cluster", func() {
 
-	Context("update cluster and addons", func() {
+	Context("control plane", func() {
 		It("should have created an EKS cluster and two CloudFormation stacks", func() {
 			config := NewConfig(params.Region)
 
@@ -139,7 +139,9 @@ var _ = Describe("(Integration) Update addons", func() {
 				return fmt.Sprintf("%s.%s", serverVersion.Major, strings.TrimSuffix(serverVersion.Minor, "+"))
 			}, k8sUpdatePollTimeout, k8sUpdatePollInterval).Should(Equal(nextEKSVersion))
 		})
+	})
 
+	Context("addons", func() {
 		It("should upgrade kube-proxy", func() {
 			cmd := params.EksctlUtilsCmd.WithArgs(
 				"update-kube-proxy",
@@ -195,6 +197,9 @@ var _ = Describe("(Integration) Update addons", func() {
 			Expect(cmd).To(RunSuccessfully())
 		})
 
+	})
+
+	Context("nodegroup", func() {
 		It("should upgrade the nodegroup to the next version", func() {
 			cmd := params.EksctlUpgradeCmd.WithArgs(
 				"nodegroup",
@@ -205,6 +210,14 @@ var _ = Describe("(Integration) Update addons", func() {
 				"--timeout=60m", // wait for CF stacks to finish update
 			)
 			ExpectWithOffset(1, cmd).To(RunSuccessfullyWithOutputString(ContainSubstring("nodegroup successfully upgraded")))
+
+			cmd = params.EksctlGetCmd.WithArgs(
+				"nodegroup",
+				"--cluster", params.ClusterName,
+				"--name", initNG,
+				"--output", "yaml",
+			)
+			ExpectWithOffset(1, cmd).To(RunSuccessfullyWithOutputString(ContainSubstring(fmt.Sprintf("Version: \"%s\"", nextEKSVersion))))
 		})
 	})
 })