TaskIq opentelemetry not working with AppWrapper

[yann-combarnous]

Per https://github.com/taskiq-python/taskiq/blob/2ed2bd64cdb944c978ff132ca5afd988ed73dad3/taskiq/instrumentation.py#L79, Taskiq is supposed to inject the taskiq otel middleware to the broker.

I tried below code and unfortunately, getting errors such as:
"<LogRecord: asyncio, 40, /usr/local/lib/python3.13/asyncio/base_events.py, 1879, "Task exception was never retrieved
future: <Task finished name='schedule_ef8554ca636942c1adcc69c931eab22a' coro=<send() done, defined at /usr/local/lib/python3.13/site-packages/taskiq/cli/scheduler/run.py:156> exception=taskiq.exceptions.SendTaskError()>">"

....
from faststream import FastStream
from taskiq_faststream import AppWrapper
from taskiq.middlewares.opentelemetry_middleware import OpenTelemetryMiddleware

broker = KafkaBroker(
    kafka_instance=...,
    consumer_group=...,
)

app = AsgiFastStream(
    broker,
    asgi_routes=[
        ("/liveness", liveness_ping),
    ],
)

# Enable OpenTelemetry middleware
taskiq_broker = AppWrapper(app, middlewares=[OpenTelemetryMiddleware()])