|
13 | 13 |
|
14 | 14 |
|
15 | 15 | class ListRedisScheduleSource(ScheduleSource): |
16 | | - """Schecule source based on arrays.""" |
| 16 | + """Schedule source based on arrays.""" |
17 | 17 |
|
18 | 18 | def __init__( |
19 | 19 | self, |
20 | 20 | url: str, |
21 | 21 | prefix: str = "schedule", |
22 | 22 | max_connection_pool_size: Optional[int] = None, |
23 | 23 | serializer: Optional[TaskiqSerializer] = None, |
24 | | - bufffer_size: int = 50, |
| 24 | + buffer_size: int = 50, |
25 | 25 | skip_past_schedules: bool = False, |
26 | 26 | **connection_kwargs: Any, |
27 | 27 | ) -> None: |
28 | 28 | super().__init__() |
29 | 29 | self._prefix = prefix |
30 | | - self._buffer_size = bufffer_size |
| 30 | + self._buffer_size = buffer_size |
31 | 31 | self._connection_pool = BlockingConnectionPool.from_url( |
32 | 32 | url=url, |
33 | 33 | max_connections=max_connection_pool_size, |
@@ -185,11 +185,11 @@ async def get_schedules(self) -> List["ScheduledTask"]: |
185 | 185 | async with Redis(connection_pool=self._connection_pool) as redis: |
186 | 186 | buffer = [] |
187 | 187 | crons = await redis.lrange(self._get_cron_key(), 0, -1) # type: ignore |
188 | | - logger.debug("Got cron scheduleds: %s", crons) |
| 188 | + logger.debug("Got %d cron schedules", len(crons)) |
189 | 189 | if crons: |
190 | 190 | buffer.extend(crons) |
191 | 191 | timed.extend(await redis.lrange(self._get_time_key(current_time), 0, -1)) # type: ignore |
192 | | - logger.debug("Got timed scheduleds: %s", crons) |
| 192 | + logger.debug("Got %d timed schedules", len(timed)) |
193 | 193 | if timed: |
194 | 194 | buffer.extend(timed) |
195 | 195 | while buffer: |
|
0 commit comments