Skip to content

Commit

Permalink
Add debug statement
Browse files Browse the repository at this point in the history
  • Loading branch information
johscheuer committed Sep 26, 2023
1 parent 65e8480 commit 9cf27d9
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions e2e/test_operator/operator_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -753,12 +753,17 @@ var _ = Describe("Operator", Label("e2e", "pr"), func() {
BeforeEach(func() {
currentGeneration := fdbCluster.GetCluster().Generation
Expect(fdbCluster.SetProcessGroupPrefix(prefix)).NotTo(HaveOccurred())

log.Println("DEBUGGING: Wait for cluster to be reconciled, current generation:", currentGeneration)
Expect(fdbCluster.WaitForReconciliation(fixtures.MinimumGenerationOption(currentGeneration+1), fixtures.SoftReconcileOption(false)))
})

It("should add the prefix to all instances", func() {
log.Println("DEBUGGING: Cluster is reconciled, current generation:", fdbCluster.GetCluster().Generation)
Eventually(func(g Gomega) bool {
for _, processGroup := range fdbCluster.GetCluster().Status.ProcessGroups {
log.Println("DEBUGGING: ProcessGroup:", processGroup.String())

g.Expect(string(processGroup.ProcessGroupID)).To(HavePrefix(prefix))
}

Expand All @@ -768,6 +773,7 @@ var _ = Describe("Operator", Label("e2e", "pr"), func() {
Eventually(func(g Gomega) bool {
pods := fdbCluster.GetPods()
for _, pod := range pods.Items {
log.Println("DEBUGGING: Pod:", pod.ObjectMeta.String())
g.Expect(string(fixtures.GetProcessGroupID(pod))).To(HavePrefix(prefix))
}

Expand Down

0 comments on commit 9cf27d9

Please sign in to comment.