diff --git a/e2e/dragonfly_controller_test.go b/e2e/dragonfly_controller_test.go index c55b6e1..eb0c439 100644 --- a/e2e/dragonfly_controller_test.go +++ b/e2e/dragonfly_controller_test.go @@ -307,7 +307,7 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func() Expect(err).To(BeNil()) time.Sleep(30 * time.Second) - // Wait until Dragonfly object is marked resources-created + // Wait until Dragonfly object is marked ready err = waitForDragonflyPhase(ctx, k8sClient, name, namespace, controller.PhaseReady, 3*time.Minute) Expect(err).To(BeNil()) err = waitForStatefulSetReady(ctx, k8sClient, name, namespace, 3*time.Minute) diff --git a/e2e/util.go b/e2e/util.go index 84605db..589544a 100644 --- a/e2e/util.go +++ b/e2e/util.go @@ -68,7 +68,7 @@ func isStatefulSetReady(ctx context.Context, c client.Client, name, namespace st return false, nil } - if statefulSet.Status.ReadyReplicas == *statefulSet.Spec.Replicas { + if statefulSet.Status.ReadyReplicas == *statefulSet.Spec.Replicas && statefulSet.Status.CurrentRevision == statefulSet.Status.UpdateRevision { return true, nil }