Add tracing to faststream asgi health-check

Author: insani7y

microbootstrap/bootstrappers/faststream.py

@@ -8,6 +8,7 @@
 from faststream.asgi import AsgiFastStream, AsgiResponse
 from faststream.asgi import get as handle_get
 from faststream.specification import AsyncAPI
+from opentelemetry import trace
 
 from microbootstrap.bootstrappers.base import ApplicationBootstrapper
 from microbootstrap.config.faststream import FastStreamConfig
@@ -23,6 +24,9 @@
 from microbootstrap.settings import FastStreamSettings
 
 
+tracer: typing.Final = trace.get_tracer(__name__)
+
+
 class KwargsAsgiFastStream(AsgiFastStream):
     def __init__(self, **kwargs: typing.Any) -> None:  # noqa: ANN401
         # `broker` argument is positional-only
@@ -107,6 +111,7 @@ def get_config_type(cls) -> type[FastStreamPrometheusConfig]:
 class FastStreamHealthChecksInstrument(HealthChecksInstrument):
     def bootstrap(self) -> None: ...
     def bootstrap_before(self) -> dict[str, typing.Any]:
+        @tracer.start_as_current_span(f"GET {self.instrument_config.health_checks_path}")
         @handle_get
         async def check_health(scope: typing.Any) -> AsgiResponse:  # noqa: ANN401, ARG001
             return (