fix: annotate TimersBroker._subscribers as WeakSet for ty 0.0.87

faststream_redis_timers/broker.py

@@ -2,6 +2,7 @@
 import typing
 from collections.abc import Iterable, Sequence
 from datetime import datetime, timedelta
+from weakref import WeakSet
 
 from fast_depends.dependencies import Dependant
 from faststream import BaseMiddleware
@@ -25,7 +26,6 @@
 from faststream_redis_timers.configs import ConnectionState, RedisClient, TimersBrokerConfig
 from faststream_redis_timers.message import TimerMessage
 from faststream_redis_timers.publisher.producer import TimersProducer
-from faststream_redis_timers.publisher.usecase import TimersPublisher
 from faststream_redis_timers.registrator import TimersRegistrator
 from faststream_redis_timers.response import TimerPublishCommand, resolve_activate_at
 from faststream_redis_timers.store import TimerStore
@@ -109,8 +109,7 @@ class TimersBroker(
     brokers; making the broker close it would break that pattern.
     """
 
-    _subscribers: list[TimersSubscriber]
-    _publishers: list[TimersPublisher]
+    _subscribers: WeakSet[TimersSubscriber]  # ty: ignore[invalid-attribute-override]
 
     @property
     @override

faststream_redis_timers/publisher/config.py

@@ -10,7 +10,7 @@
 
 @dataclass(kw_only=True)
 class TimersPublisherConfig(PublisherUsecaseConfig):
-    _outer_config: "TimersBrokerConfig"
+    _outer_config: "TimersBrokerConfig"  # ty: ignore[invalid-mutable-override]
     topic: str
 
     @property

faststream_redis_timers/subscriber/config.py

@@ -13,7 +13,7 @@
 
 @dataclass(kw_only=True)
 class TimersSubscriberConfig(SubscriberUsecaseConfig):
-    _outer_config: "TimersBrokerConfig"
+    _outer_config: "TimersBrokerConfig"  # ty: ignore[invalid-mutable-override]
     timer_sub: TimerSub
 
     @property

faststream_redis_timers/subscriber/usecase.py

@@ -55,7 +55,7 @@ def get_schema(self) -> dict[str, SubscriberSpec]:
 
 
 class TimersSubscriber(TasksMixin, SubscriberUsecase[TimerMessage]):
-    _outer_config: "TimersBrokerConfig"
+    _outer_config: "TimersBrokerConfig"  # ty: ignore[invalid-mutable-override]
 
     def __init__(
         self,