Skip to content

support faststream 0.6 #54

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Oct 15, 2025
Merged

support faststream 0.6 #54

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 6 additions & 7 deletions lite_bootstrap/bootstrappers/faststream_bootstrapper.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,9 @@


if import_checker.is_faststream_installed:
import faststream
from faststream._internal.broker import BrokerUsecase
from faststream.asgi import AsgiFastStream, AsgiResponse
from faststream.asgi import get as handle_get
from faststream.broker.core.usecase import BrokerUsecase

if import_checker.is_prometheus_client_installed:
import prometheus_client
Expand All @@ -33,8 +32,8 @@ def __init__(
tracer_provider: typing.Optional["TracerProvider"] = None,
meter_provider: typing.Optional["MeterProvider"] = None,
meter: typing.Optional["Meter"] = None,
include_messages_counters: bool = True,
) -> None: ...
def __call__(self, msg: typing.Any | None) -> "faststream.BaseMiddleware": ... # noqa: ANN401


@typing.runtime_checkable
Expand All @@ -47,7 +46,6 @@ def __init__(
metrics_prefix: str = "faststream",
received_messages_size_buckets: typing.Sequence[float] | None = None,
) -> None: ...
def __call__(self, msg: typing.Any | None) -> "faststream.BaseMiddleware": ... # noqa: ANN401


@dataclasses.dataclass(kw_only=True, slots=True, frozen=True)
Expand Down Expand Up @@ -103,8 +101,9 @@ def is_ready(self) -> bool:

def bootstrap(self) -> None:
if self.bootstrap_config.opentelemetry_middleware_cls and self.bootstrap_config.application.broker:
self.bootstrap_config.opentelemetry_middleware_cls(tracer_provider=get_tracer_provider())
self.bootstrap_config.application.broker.add_middleware(
self.bootstrap_config.opentelemetry_middleware_cls(tracer_provider=get_tracer_provider())
self.bootstrap_config.opentelemetry_middleware_cls(tracer_provider=get_tracer_provider()) # type: ignore[arg-type]
)


Expand Down Expand Up @@ -139,7 +138,7 @@ def bootstrap(self) -> None:
)
if self.bootstrap_config.prometheus_middleware_cls and self.bootstrap_config.application.broker:
self.bootstrap_config.application.broker.add_middleware(
self.bootstrap_config.prometheus_middleware_cls(registry=self.collector_registry)
self.bootstrap_config.prometheus_middleware_cls(registry=self.collector_registry) # type: ignore[arg-type]
)


Expand All @@ -162,7 +161,7 @@ def is_ready(self) -> bool:
def __init__(self, bootstrap_config: FastStreamConfig) -> None:
super().__init__(bootstrap_config)
if self.bootstrap_config.broker:
self.bootstrap_config.application.broker = self.bootstrap_config.broker
self.bootstrap_config.application.set_broker(self.bootstrap_config.broker)
self.bootstrap_config.application.on_shutdown(self.teardown)

def _prepare_application(self) -> "AsgiFastStream":
Expand Down
2 changes: 1 addition & 1 deletion tests/test_faststream_bootstrap.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

import pytest
import structlog
from faststream.broker.core.usecase import BrokerUsecase
from faststream._internal.broker import BrokerUsecase
from faststream.redis import RedisBroker, TestRedisBroker
from faststream.redis.opentelemetry import RedisTelemetryMiddleware
from faststream.redis.prometheus import RedisPrometheusMiddleware
Expand Down
Loading