Wait for Tekton metrics in E2E Test (#24163)

* Wait for Tekton trigger metrics in E2E

* Add type hints to Tekton metric wait helper

Author: nubtron

tekton/tests/conftest.py

@@ -3,10 +3,12 @@
 # Licensed under a 3-clause BSD style license (see LICENSE)
 import os
 from contextlib import ExitStack
+from urllib.request import urlopen
 
 import pytest
 
 from datadog_checks.dev import get_here, run_command
+from datadog_checks.dev.conditions import WaitFor
 from datadog_checks.dev.kind import kind_run
 from datadog_checks.dev.kube_port_forward import port_forward
 
@@ -21,6 +23,15 @@ def _wait_for_resource(*, kind, name, condition, namespace=None, timeout="300s")
     run_command(command)
 
 
+def wait_for_metric_families(endpoint: str, families: list[str]) -> None:
+    with urlopen(endpoint, timeout=5) as response:
+        metrics = response.read().decode("utf-8")
+
+    missing = [family for family in families if family not in metrics]
+    if missing:
+        raise AssertionError("Tekton metric families are not available yet: {}".format(", ".join(missing)))
+
+
 def setup_tekton():
     run_command(["kubectl", "create", "namespace", "tekton-operator"])
     run_command(["kubectl", "apply", "-f", os.path.join(HERE, "kind", "tekton-operator.yaml"), "-n", "tekton-operator"])
@@ -77,6 +88,22 @@ def dd_environment():
         )
         instances['triggers_controller_endpoint'] = f'http://{trigger_host}:{trigger_port}/metrics'
 
+        WaitFor(
+            wait_for_metric_families,
+            attempts=60,
+            wait=2,
+            args=(
+                instances['triggers_controller_endpoint'],
+                [
+                    'controller_clusterinterceptor_count',
+                    'controller_clustertriggerbinding_count',
+                    'controller_eventlistener_count',
+                    'controller_triggerbinding_count',
+                    'controller_triggertemplate_count',
+                ],
+            ),
+        )()
+
         yield {'instances': [instances]}