Adds a waiter for the pods to switch to the ACTIVE state

Author: Stanislav Koshchienko

test/e2e/application_image_test.go

@@ -18,6 +18,7 @@ package e2e
 
 import (
 	"context"
+	"fmt"
 	"time"
 
 	. "github.com/onsi/ginkgo/v2"
@@ -77,9 +78,27 @@ var _ = Describe("WebServerControllerTest", Ordered, func() {
 		It("Update Test", func() {
 			var createdWebserver *webserversv1alpha1.WebServer
 
-			// Update WebImage and update WebServer
+			// Wait for all pods to go into "ACTIVE" State
 			Eventually(func() bool {
 				createdWebserver = getWebServer(name)
+
+				if len(createdWebserver.Status.Pods) != int(createdWebserver.Spec.Replicas) {
+					return false
+				}
+
+				for _, pod := range createdWebserver.Status.Pods {
+					if pod.State != webserversv1alpha1.PodStateActive {
+						fmt.Printf("Pod %s is in state %s\n", pod.Name, pod.State)
+						return false
+					}
+				}
+
+				return true
+
+			}, time.Minute*3, time.Second*2).Should(BeTrue(), "Not all pods got to ACTIVE state")
+
+			// Update WebImage and update WebServer
+			Eventually(func() bool {
 				createdWebserver.Spec.WebImage.ApplicationImage = newImage
 
 				err := k8sClient.Update(ctx, createdWebserver)