wait for catalogsource ready (#2601)

akihikokuroda · web-flow · commit 559319599b1a · 2022-01-26T21:08:14.000-05:00
Signed-off-by: akihikokuroda &lt;akihikokuroda2020@gmail.com&gt;
diff --git a/test/e2e/subscription_e2e_test.go b/test/e2e/subscription_e2e_test.go
@@ -95,6 +95,8 @@ var _ = Describe("Subscription", func() {
 			}
 
 			_, teardown = createInternalCatalogSource(ctx.Ctx().KubeClient(), ctx.Ctx().OperatorClient(), "test-catalog", generatedNamespace.GetName(), packages, crds, csvs)
+			_, err := fetchCatalogSourceOnStatus(ctx.Ctx().OperatorClient(), "test-catalog", generatedNamespace.GetName(), catalogSourceRegistryPodSynced)
+			Expect(err).NotTo(HaveOccurred())
 
 			createSubscriptionForCatalog(ctx.Ctx().OperatorClient(), generatedNamespace.GetName(), "test-subscription", "test-catalog", "root", "channel-root", "", operatorsv1alpha1.ApprovalAutomatic)
 		})

Original file line number	Diff line number	Diff line change
`@@ -95,6 +95,8 @@ var _ = Describe("Subscription", func() {`
`95`	`95`	`}`
`96`	`96`
`97`	`97`	`_, teardown = createInternalCatalogSource(ctx.Ctx().KubeClient(), ctx.Ctx().OperatorClient(), "test-catalog", generatedNamespace.GetName(), packages, crds, csvs)`
	`98`	`+ _, err := fetchCatalogSourceOnStatus(ctx.Ctx().OperatorClient(), "test-catalog", generatedNamespace.GetName(), catalogSourceRegistryPodSynced)`
	`99`	`+ Expect(err).NotTo(HaveOccurred())`
`98`	`100`
`99`	`101`	`createSubscriptionForCatalog(ctx.Ctx().OperatorClient(), generatedNamespace.GetName(), "test-subscription", "test-catalog", "root", "channel-root", "", operatorsv1alpha1.ApprovalAutomatic)`
`100`	`102`	`})`