From 187e277e21ef1a6192fc20542de91d81ab79bdfa Mon Sep 17 00:00:00 2001 From: Artur Shiriev Date: Tue, 10 Nov 2026 22:13:04 +0300 Subject: [PATCH] Update ty ignore codes for 0.0.100 Refs #273 --- benchmarks/probes.py | 2 +- faststream_outbox/broker.py | 8 ++++---- faststream_outbox/client.py | 2 +- faststream_outbox/fastapi/router.py | 6 +++--- faststream_outbox/publisher/config.py | 2 +- faststream_outbox/publisher/usecase.py | 4 ++-- faststream_outbox/registrator.py | 4 ++-- faststream_outbox/subscriber/config.py | 2 +- faststream_outbox/subscriber/usecase.py | 6 +++--- tests/test_unit.py | 2 +- 10 files changed, 19 insertions(+), 19 deletions(-) diff --git a/benchmarks/probes.py b/benchmarks/probes.py index 61069f1..f3af2a9 100644 --- a/benchmarks/probes.py +++ b/benchmarks/probes.py @@ -243,7 +243,7 @@ async def probe(engine: AsyncEngine, table_name: str, schema: str | None = None) yield sink - checked_out = engine.pool.checkedout() # ty: ignore[unresolved-attribute] + checked_out = engine.pool.checkedout() # ty: ignore[missing-attribute] if checked_out: msg = ( f"{checked_out} connection(s) are still checked out of the pool. " diff --git a/faststream_outbox/broker.py b/faststream_outbox/broker.py index 31d16f4..15ee369 100644 --- a/faststream_outbox/broker.py +++ b/faststream_outbox/broker.py @@ -126,7 +126,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]" # ty: ignore[invalid-attribute-override] + _subscribers: "WeakSet[OutboxSubscriber]" # ty: ignore[incompatible-attribute-override] def __init__( # noqa: PLR0913 self, @@ -324,7 +324,7 @@ def _warn_on_unstarted_foreign_publishers(self) -> None: for sub in self.subscribers: for call in sub.calls: for pub in call.handler._publishers: # noqa: SLF001 - outer = pub._outer_config # noqa: SLF001 # ty: ignore[unresolved-attribute] + outer = pub._outer_config # noqa: SLF001 # ty: ignore[missing-attribute] # An internal outbox publisher's ``outer`` is this broker's own config, # which carries a (truthy) ``producer`` — so the wired-producer check # below already skips it; no separate ``outer is self.config`` branch needed. @@ -434,7 +434,7 @@ async def validate_schema(self, *, check_autovacuum: bool = False) -> None: await self.client.validate_schema(check_autovacuum=check_autovacuum) # Deliberate signature divergence: the outbox contract adds session/activate_*/timer_id. - async def publish( # ty: ignore[invalid-method-override] + async def publish( # ty: ignore[incompatible-method-override] self, body: typing.Any, *, @@ -486,7 +486,7 @@ async def publish( # ty: ignore[invalid-method-override] return typing.cast("int | None", result) # Deliberate signature divergence: the outbox contract adds session/activate_*. - async def publish_batch( # ty: ignore[invalid-method-override] + async def publish_batch( # ty: ignore[incompatible-method-override] self, *bodies: typing.Any, queue: str, diff --git a/faststream_outbox/client.py b/faststream_outbox/client.py index bff2b14..71aba23 100644 --- a/faststream_outbox/client.py +++ b/faststream_outbox/client.py @@ -673,7 +673,7 @@ async def cancel_timer(self, *, queue: str, timer_id: str, session: SessionOrCon t.c.acquired_token.is_(None), ) result = await session.execute(stmt) - return (result.rowcount or 0) > 0 # ty: ignore[unresolved-attribute] + return (result.rowcount or 0) > 0 # ty: ignore[missing-attribute] async def fetch_unprocessed( self, diff --git a/faststream_outbox/fastapi/router.py b/faststream_outbox/fastapi/router.py index 4da284e..af2e60b 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 # ty: ignore[invalid-mutable-override] + broker: _OutboxBroker # ty: ignore[incompatible-mutable-override] def __init__( # noqa: PLR0913 self, @@ -156,7 +156,7 @@ def __init__( # noqa: PLR0913 generate_unique_id_function=generate_unique_id_function, ) - def subscriber( # ty: ignore[invalid-method-override] # noqa: PLR0913 + def subscriber( # ty: ignore[incompatible-method-override] # noqa: PLR0913 self, queues: str | list[str], *, @@ -222,7 +222,7 @@ def subscriber( # ty: ignore[invalid-method-override] # noqa: PLR0913 ), ) - def publisher( # ty: ignore[invalid-method-override] + def publisher( # ty: ignore[incompatible-method-override] self, queue: str, *, diff --git a/faststream_outbox/publisher/config.py b/faststream_outbox/publisher/config.py index 081a81e..d3ffd5c 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" # ty: ignore[invalid-mutable-override] + _outer_config: "OutboxBrokerConfig" # ty: ignore[incompatible-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 caf8097..a0fa32d 100644 --- a/faststream_outbox/publisher/usecase.py +++ b/faststream_outbox/publisher/usecase.py @@ -42,7 +42,7 @@ class OutboxPublisher(PublisherUsecase): """Queue-scoped publisher. Standalone use only — no relay decorator support.""" - _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] + _outer_config: "OutboxBrokerConfig" # ty: ignore[incompatible-mutable-override] def __init__( self, @@ -65,7 +65,7 @@ def __call__( ) -> "HandlerCallWrapper[P_HandlerParams, T_HandlerReturn]": raise NotImplementedError(_REJECT_RELAY_MSG) - async def publish( # ty: ignore[invalid-method-override] + async def publish( # ty: ignore[incompatible-method-override] self, body: typing.Any, # parity with broker.publish (both build OutboxPublishCommand(body: Any)) *, diff --git a/faststream_outbox/registrator.py b/faststream_outbox/registrator.py index e988026..706ca13 100644 --- a/faststream_outbox/registrator.py +++ b/faststream_outbox/registrator.py @@ -23,7 +23,7 @@ class OutboxRegistrator(Registrator[OutboxInnerMessage, "OutboxBrokerConfig"]): # ty: ignore[unresolved-reference] @override - def subscriber( # ty: ignore[invalid-method-override] + def subscriber( # ty: ignore[incompatible-method-override] self, queues: str | list[str], *, @@ -108,7 +108,7 @@ def include_router( ) @override - def publisher( # ty: ignore[invalid-method-override] + def publisher( # ty: ignore[incompatible-method-override] self, queue: str, *, diff --git a/faststream_outbox/subscriber/config.py b/faststream_outbox/subscriber/config.py index e54ed12..dde7201 100644 --- a/faststream_outbox/subscriber/config.py +++ b/faststream_outbox/subscriber/config.py @@ -66,7 +66,7 @@ def _validate_queues(queues: list[str]) -> None: @dataclass(kw_only=True) class OutboxSubscriberConfig(SubscriberUsecaseConfig): - _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] + _outer_config: "OutboxBrokerConfig" # ty: ignore[incompatible-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 ad4a77a..a32568f 100644 --- a/faststream_outbox/subscriber/usecase.py +++ b/faststream_outbox/subscriber/usecase.py @@ -191,7 +191,7 @@ def get_schema(self) -> dict[str, SubscriberSpec]: class OutboxSubscriber(TasksMixin, SubscriberUsecase[OutboxInnerMessage]): - _outer_config: "OutboxBrokerConfig" # ty: ignore[invalid-mutable-override] + _outer_config: "OutboxBrokerConfig" # ty: ignore[incompatible-mutable-override] def __init__( self, @@ -1108,7 +1108,7 @@ async def process_message(self, msg: OutboxInnerMessage) -> "Response": # noqa: stack.enter_context(context.scope(k, v)) middlewares: list[typing.Any] = [] - for base_m in self._SubscriberUsecase__build__middlewares_stack(): # ty: ignore[unresolved-attribute] + for base_m in self._SubscriberUsecase__build__middlewares_stack(): # ty: ignore[missing-attribute] middleware = base_m(msg, context=context) middlewares.append(middleware) await middleware.__aenter__() @@ -1146,7 +1146,7 @@ async def process_message(self, msg: OutboxInnerMessage) -> "Response": # noqa: self._reject_outbox_response_with_foreign_publisher(result_msg, h.handler) for p in chain( - self._SubscriberUsecase__get_response_publisher(message), # ty: ignore[unresolved-attribute] + self._SubscriberUsecase__get_response_publisher(message), # ty: ignore[missing-attribute] h.handler._publishers, # noqa: SLF001 ): await p._publish( # noqa: SLF001 diff --git a/tests/test_unit.py b/tests/test_unit.py index f6c78cf..1bea121 100644 --- a/tests/test_unit.py +++ b/tests/test_unit.py @@ -1529,7 +1529,7 @@ async def handle(body: dict) -> None: ... assert all(s not in broker._subscribers for s in subs) # noqa: SLF001 done_task = MagicMock() done_task.done.return_value = True - subs[0].tasks = [done_task] # ty: ignore[unresolved-attribute] + subs[0].tasks = [done_task] # ty: ignore[missing-attribute] assert await broker.ping() is False