Add debug log in K8sUtil.waitForPodStateRunning()

hivemq · Dec 4, 2024 · 32281d3 · 32281d3
1 parent ed51e6f
commit 32281d3
Showing 1 changed file with 11 additions and 5 deletions.
diff --git a/...hivemq-platform-operator/src/integrationTest/java/com/hivemq/helmcharts/util/K8sUtil.java b/...hivemq-platform-operator/src/integrationTest/java/com/hivemq/helmcharts/util/K8sUtil.java
@@ -614,11 +614,17 @@ public static void waitForPodStateRunning(
                 .inNamespace(namespace)
                 .withLabels(labels)
                 .waitUntilCondition(pod -> pod != null &&
-                        pod.getStatus()
-                                .getContainerStatuses()
-                                .stream()
-                                .allMatch(containerStatus -> containerStatus.getReady() &&
-                                        containerStatus.getStarted()), 3, TimeUnit.MINUTES);
+                        pod.getStatus().getContainerStatuses().stream().allMatch(containerStatus -> {
+                            final var ready = containerStatus.getReady() && containerStatus.getStarted();
+                            if (ready) {
+                                LOG.info("Pod '{}' is ready", pod.getMetadata().getName());
+                            } else {
+                                LOG.debug("Waiting for Pod '{}' to be ready: {}",
+                                        pod.getMetadata().getName(),
+                                        containerStatus);
+                            }
+                            return ready;
+                        }), 3, TimeUnit.MINUTES);
     }
 
     private static <T extends HasMetadata> @NotNull Resource<T> loadResource(