From f84ea9ac348fb8315682f11ffeebd900a6f49c3b Mon Sep 17 00:00:00 2001 From: Artur Shiriev Date: Wed, 14 Oct 2026 17:04:35 +0300 Subject: [PATCH] fix: silence ty 0.0.87 override checks on narrowed faststream attributes --- faststream_outbox/broker.py | 2 +- faststream_outbox/fastapi/router.py | 2 +- faststream_outbox/publisher/config.py | 2 +- faststream_outbox/publisher/usecase.py | 2 +- faststream_outbox/subscriber/config.py | 2 +- faststream_outbox/subscriber/usecase.py | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/faststream_outbox/broker.py b/faststream_outbox/broker.py index e72d947..2c01e57 100644 --- a/faststream_outbox/broker.py +++ b/faststream_outbox/broker.py @@ -124,7 +124,7 @@ class OutboxBroker( # P25: the runtime container is a WeakSet (set by the upstream Registrator), not a # list — annotate it accurately so the _subscribers/subscribers distinction is clear. - _subscribers: "WeakSet[OutboxSubscriber]" + _subscribers: "WeakSet[OutboxSubscriber]" # ty: ignore[invalid-attribute-override] def __init__( # noqa: PLR0913 self, diff --git a/faststream_outbox/fastapi/router.py b/faststream_outbox/fastapi/router.py index 005b77b..9b71015 100644 --- a/faststream_outbox/fastapi/router.py +++ b/faststream_outbox/fastapi/router.py @@ -63,7 +63,7 @@ class OutboxRouter(StreamRouter[OutboxInnerMessage]): """FastAPI router for the outbox transport.""" broker_class = _OutboxBroker - broker: _OutboxBroker + broker: _OutboxBroker # ty: ignore[invalid-mutable-override] def __init__( # noqa: PLR0913 self, diff --git a/faststream_outbox/publisher/config.py b/faststream_outbox/publisher/config.py index 3c6dbce..081a81e 100644 --- a/faststream_outbox/publisher/config.py +++ b/faststream_outbox/publisher/config.py @@ -12,7 +12,7 @@ @dataclass(kw_only=True) class OutboxPublisherConfig(PublisherUsecaseConfig): - _outer_config: "OutboxBrokerConfig" + _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] queue: str headers: dict[str, str] | None = None diff --git a/faststream_outbox/publisher/usecase.py b/faststream_outbox/publisher/usecase.py index a2fc7ed..9e2932c 100644 --- a/faststream_outbox/publisher/usecase.py +++ b/faststream_outbox/publisher/usecase.py @@ -41,7 +41,7 @@ class OutboxPublisher(PublisherUsecase): """Queue-scoped publisher. Standalone use only — no relay decorator support.""" - _outer_config: "OutboxBrokerConfig" + _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] def __init__( self, diff --git a/faststream_outbox/subscriber/config.py b/faststream_outbox/subscriber/config.py index 47d7216..6c84634 100644 --- a/faststream_outbox/subscriber/config.py +++ b/faststream_outbox/subscriber/config.py @@ -47,7 +47,7 @@ def _subscriber_warn(message: str) -> None: @dataclass(kw_only=True) class OutboxSubscriberConfig(SubscriberUsecaseConfig): - _outer_config: "OutboxBrokerConfig" + _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] queues: list[str] max_workers: int retry_strategy: "RetryStrategyProto | None" diff --git a/faststream_outbox/subscriber/usecase.py b/faststream_outbox/subscriber/usecase.py index a6c6e22..7989635 100644 --- a/faststream_outbox/subscriber/usecase.py +++ b/faststream_outbox/subscriber/usecase.py @@ -192,7 +192,7 @@ def get_schema(self) -> dict[str, SubscriberSpec]: class OutboxSubscriber(TasksMixin, SubscriberUsecase[OutboxInnerMessage]): - _outer_config: "OutboxBrokerConfig" + _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] def __init__( self,