wait for condition update

Signed-off-by: akihikokuroda <[email protected]>

Author: akihikokuroda

test/e2e/installplan_e2e_test.go

@@ -3193,13 +3193,23 @@ var _ = Describe("Install Plan", func() {
 		It("should clear clear up the condition in the InstallPlan status that contains an error message when a valid OperatorGroup is created", func() {
 
 			// first check that a condition with a message exists
-			fetchedInstallPlan, err := fetchInstallPlanWithNamespace(GinkgoT(), crc, installPlanName, ns.GetName(), buildInstallPlanPhaseCheckFunc(operatorsv1alpha1.InstallPlanPhaseInstalling))
-			Expect(err).NotTo(HaveOccurred())
-			Expect(fetchedInstallPlan).NotTo(BeNil())
 			cond := operatorsv1alpha1.InstallPlanCondition{Type: operatorsv1alpha1.InstallPlanInstalled, Status: corev1.ConditionFalse, Reason: operatorsv1alpha1.InstallPlanReasonInstallCheckFailed,
 				Message: "no operator group found that is managing this namespace"}
-			Expect(fetchedInstallPlan.Status.Phase).To(Equal(operatorsv1alpha1.InstallPlanPhaseInstalling))
-			Expect(hasCondition(fetchedInstallPlan, cond)).To(BeTrue())
+			Eventually(
+				func() (bool, error) {
+					fetchedInstallPlan, err := fetchInstallPlanWithNamespace(GinkgoT(), crc, installPlanName, ns.GetName(), buildInstallPlanPhaseCheckFunc(operatorsv1alpha1.InstallPlanPhaseInstalling))
+					Expect(err).NotTo(HaveOccurred())
+					Expect(fetchedInstallPlan).NotTo(BeNil())
+					Expect(fetchedInstallPlan.Status.Phase).To(Equal(operatorsv1alpha1.InstallPlanPhaseInstalling))
+					if hasCondition(fetchedInstallPlan, cond) {
+						return true, nil
+					} else {
+						return false, nil
+					}
+				},
+				1*time.Minute,
+				interval,
+			).Should(BeTrue())
 
 			// Create an operatorgroup for the same namespace
 			og := &operatorsv1.OperatorGroup{