From 41a045b67bb04a2b25166b4f8889048e3d789b42 Mon Sep 17 00:00:00 2001 From: Abhradeep Chakraborty Date: Thu, 15 Aug 2024 20:49:48 +0530 Subject: [PATCH] debug Signed-off-by: Abhradeep Chakraborty --- e2e/dragonfly_controller_test.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/e2e/dragonfly_controller_test.go b/e2e/dragonfly_controller_test.go index fb91842..e49161d 100644 --- a/e2e/dragonfly_controller_test.go +++ b/e2e/dragonfly_controller_test.go @@ -484,12 +484,12 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func() stopChan := make(chan struct{}, 1) rc, err := checkAndK8sPortForwardRedis(ctx, clientset, cfg, stopChan, name, namespace, password, 6395) Expect(err).To(BeNil()) + defer close(stopChan) // Check for test data data, err := rc.Get(ctx, "foo").Result() Expect(err).To(BeNil()) Expect(data).To(Equal("bar")) - defer close(stopChan) }) It("Change Service specification to LoadBalancer", func() { @@ -516,10 +516,10 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func() Expect(err).To(BeNil()) // 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) + err = waitForDragonflyPhase(ctx, k8sClient, name, namespace, controller.PhaseReady, 1*time.Minute) Expect(err).To(BeNil()) + // err = waitForStatefulSetReady(ctx, k8sClient, name, namespace, 3*time.Minute) + // Expect(err).To(BeNil()) var svc corev1.Service err = k8sClient.Get(ctx, types.NamespacedName{ @@ -919,6 +919,8 @@ func isDragonflyInphase(ctx context.Context, c client.Client, name, namespace, p return false, nil } + GinkgoLogr.Info("dragonfly phase", df.Status) + // Ready means we also want rolling update to be false if phase == controller.PhaseReady { // check for replicas