fix: wait for pods to be ready before port-forwarding in MetricsHandlingE2E

Replace one-shot pod lookup with an awaitility-based readiness wait (up to 3 minutes)
to avoid IllegalStateException when pods are not yet scheduled after observability
stack installation.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

sample-operators/metrics-processing/src/test/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingE2E.java

@@ -81,15 +81,14 @@ class MetricsHandlingE2E {
               .build();
 
   @BeforeAll
-  void setupObservability() throws InterruptedException {
+  void setupObservability() {
     log.info("Setting up observability stack...");
     installObservabilityServices();
     prometheusPortForward = portForward(NAME_LABEL_KEY, "prometheus", PROMETHEUS_PORT);
     if (isLocal()) {
       otelCollectorPortForward =
           portForward(NAME_LABEL_KEY, "otel-collector-collector", OTEL_COLLECTOR_PORT);
     }
-    Thread.sleep(2000);
   }
 
   @AfterAll
@@ -99,25 +98,49 @@ void cleanup() throws IOException {
   }
 
   private LocalPortForward portForward(String labelKey, String labelValue, int port) {
+    log.info("Waiting for pod with label {}={} to be ready...", labelKey, labelValue);
+    await()
+        .atMost(Duration.ofMinutes(3))
+        .pollInterval(Duration.ofSeconds(5))
+        .until(
+            () -> {
+              var pods =
+                  client
+                      .pods()
+                      .inNamespace(OBSERVABILITY_NAMESPACE)
+                      .withLabel(labelKey, labelValue)
+                      .list()
+                      .getItems();
+              return pods.stream()
+                  .anyMatch(
+                      pod ->
+                          pod.getStatus() != null
+                              && pod.getStatus().getConditions() != null
+                              && pod.getStatus().getConditions().stream()
+                                  .anyMatch(
+                                      c ->
+                                          "Ready".equals(c.getType())
+                                              && "True".equals(c.getStatus())));
+            });
+    var pod =
+        client
+            .pods()
+            .inNamespace(OBSERVABILITY_NAMESPACE)
+            .withLabel(labelKey, labelValue)
+            .list()
+            .getItems()
+            .stream()
+            .findFirst()
+            .orElseThrow(
+                () ->
+                    new IllegalStateException(
+                        "Pod not found for label " + labelKey + "=" + labelValue));
+    log.info("Pod {} is ready, establishing port-forward on port {}", pod.getMetadata().getName(), port);
     return client
         .pods()
         .inNamespace(OBSERVABILITY_NAMESPACE)
-        .withLabel(labelKey, labelValue)
-        .list()
-        .getItems()
-        .stream()
-        .findFirst()
-        .map(
-            pod ->
-                client
-                    .pods()
-                    .inNamespace(OBSERVABILITY_NAMESPACE)
-                    .withName(pod.getMetadata().getName())
-                    .portForward(port, port))
-        .orElseThrow(
-            () ->
-                new IllegalStateException(
-                    "Pod not found for label " + labelKey + "=" + labelValue));
+        .withName(pod.getMetadata().getName())
+        .portForward(port, port);
   }
 
   private void closePortForward(LocalPortForward pf) throws IOException {