From 6f29f8aba04253b603dc1e2ddc4dea654dd3151e Mon Sep 17 00:00:00 2001 From: Artur Shiriev Date: Sat, 3 Oct 2026 23:37:50 +0300 Subject: [PATCH] refactor: drop vestigial client param from _consume --- faststream_redis_timers/subscriber/usecase.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/faststream_redis_timers/subscriber/usecase.py b/faststream_redis_timers/subscriber/usecase.py index d7b9a03..8faaa8d 100644 --- a/faststream_redis_timers/subscriber/usecase.py +++ b/faststream_redis_timers/subscriber/usecase.py @@ -80,7 +80,7 @@ async def start(self) -> None: start_signal = anyio.Event() if self.calls: - self.add_task(self._consume, (self._client,), {"start_signal": start_signal}) + self.add_task(self._consume, func_kwargs={"start_signal": start_signal}) consume_task = self.tasks[-1] try: with anyio.fail_after(self._outer_config.start_timeout): @@ -96,9 +96,9 @@ async def start(self) -> None: else: start_signal.set() - async def _consume(self, client: "RedisClient", *, start_signal: anyio.Event) -> None: + async def _consume(self, *, start_signal: anyio.Event) -> None: with suppress(Exception): - if await client.ping(): + if await self._client.ping(): start_signal.set() schedule = PollSchedule(