From 50a54762dadc80a2554d9765f971341f595cc686 Mon Sep 17 00:00:00 2001 From: Daniil Levchenko Date: Wed, 2 Apr 2025 19:14:01 +0300 Subject: [PATCH 1/3] Fix typos in docstring and variables. --- taskiq_redis/list_schedule_source.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/taskiq_redis/list_schedule_source.py b/taskiq_redis/list_schedule_source.py index 394326a..eab8c07 100644 --- a/taskiq_redis/list_schedule_source.py +++ b/taskiq_redis/list_schedule_source.py @@ -13,7 +13,7 @@ class ListRedisScheduleSource(ScheduleSource): - """Schecule source based on arrays.""" + """Schedule source based on arrays.""" def __init__( self, @@ -21,13 +21,13 @@ def __init__( prefix: str = "schedule", max_connection_pool_size: Optional[int] = None, serializer: Optional[TaskiqSerializer] = None, - bufffer_size: int = 50, + buffer_size: int = 50, skip_past_schedules: bool = False, **connection_kwargs: Any, ) -> None: super().__init__() self._prefix = prefix - self._buffer_size = bufffer_size + self._buffer_size = buffer_size self._connection_pool = BlockingConnectionPool.from_url( url=url, max_connections=max_connection_pool_size, @@ -185,11 +185,11 @@ async def get_schedules(self) -> List["ScheduledTask"]: async with Redis(connection_pool=self._connection_pool) as redis: buffer = [] crons = await redis.lrange(self._get_cron_key(), 0, -1) # type: ignore - logger.debug("Got cron scheduleds: %s", crons) + logger.debug("Got cron schedules: %s", crons) if crons: buffer.extend(crons) timed.extend(await redis.lrange(self._get_time_key(current_time), 0, -1)) # type: ignore - logger.debug("Got timed scheduleds: %s", crons) + logger.debug("Got timed schedules: %s", len(timed)) if timed: buffer.extend(timed) while buffer: From 08a9e9899c55b00b24d8ea0320f03d1a2b77df95 Mon Sep 17 00:00:00 2001 From: daniel_shtel <78212742+danielshtel@users.noreply.github.com> Date: Wed, 2 Apr 2025 19:21:43 +0300 Subject: [PATCH 2/3] Update taskiq_redis/list_schedule_source.py Co-authored-by: Pavel Kirilin --- taskiq_redis/list_schedule_source.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/taskiq_redis/list_schedule_source.py b/taskiq_redis/list_schedule_source.py index eab8c07..35bad8a 100644 --- a/taskiq_redis/list_schedule_source.py +++ b/taskiq_redis/list_schedule_source.py @@ -189,7 +189,7 @@ async def get_schedules(self) -> List["ScheduledTask"]: if crons: buffer.extend(crons) timed.extend(await redis.lrange(self._get_time_key(current_time), 0, -1)) # type: ignore - logger.debug("Got timed schedules: %s", len(timed)) + logger.debug("Got %d timed schedules", len(timed)) if timed: buffer.extend(timed) while buffer: From 4cf4150ddbe82a7e3e224c394740b3387578cd52 Mon Sep 17 00:00:00 2001 From: daniel_shtel <78212742+danielshtel@users.noreply.github.com> Date: Wed, 2 Apr 2025 19:21:50 +0300 Subject: [PATCH 3/3] Update taskiq_redis/list_schedule_source.py Co-authored-by: Pavel Kirilin --- taskiq_redis/list_schedule_source.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/taskiq_redis/list_schedule_source.py b/taskiq_redis/list_schedule_source.py index 35bad8a..1350f6e 100644 --- a/taskiq_redis/list_schedule_source.py +++ b/taskiq_redis/list_schedule_source.py @@ -185,7 +185,7 @@ async def get_schedules(self) -> List["ScheduledTask"]: async with Redis(connection_pool=self._connection_pool) as redis: buffer = [] crons = await redis.lrange(self._get_cron_key(), 0, -1) # type: ignore - logger.debug("Got cron schedules: %s", crons) + logger.debug("Got %d cron schedules", len(crons)) if crons: buffer.extend(crons) timed.extend(await redis.lrange(self._get_time_key(current_time), 0, -1)) # type: ignore