Fixed rediscluster schedule source.

Signed-off-by: Pavel Kirilin <[email protected]>

Author: s3rius

taskiq_redis/schedule_source.py

@@ -156,19 +156,14 @@ async def get_schedules(self) -> List[ScheduledTask]:
         :return: list of schedules.
         """
         schedules = []
-        buffer = []
         async for key in self.redis.scan_iter(f"{self.prefix}:*"):  # type: ignore[attr-defined]
-            buffer.append(key)
-            if len(buffer) >= self.buffer_size:
-                schedules.extend(await self.redis.mget(buffer))  # type: ignore[attr-defined]
-                buffer = []
-        if buffer:
-            schedules.extend(await self.redis.mget(buffer))  # type: ignore[attr-defined]
-        return [
-            model_validate(ScheduledTask, self.serializer.loadb(schedule))
-            for schedule in schedules
-            if schedule
-        ]
+            raw_schedule = await self.redis.get(key)
+            parsed_schedule = model_validate(
+                ScheduledTask,
+                self.serializer.loadb(raw_schedule),
+            )
+            schedules.append(parsed_schedule)
+        return schedules
 
     async def post_send(self, task: ScheduledTask) -> None:
         """Delete a task after it's completed."""