ListRedisScheduleSource do not support schedule_by_interval - schedules are stored but never executed #115

async def add_schedule(self, schedule: "ScheduledTask") -> None:
    async with Redis(connection_pool=self._connection_pool) as redis:
        await redis.set(
            f"{self._prefix}:data:{schedule.schedule_id}",
            self._serializer.dumpb(model_dump(schedule)),
        )
        if schedule.cron is not None:
            await redis.rpush(self._get_cron_key(), schedule.schedule_id)
        elif schedule.time is not None:
            await redis.rpush(self._get_time_key(schedule.time), schedule.schedule_id)
        # ⚠️ schedule.interval is NOT handled - data is saved but never indexed

from datetime import timedelta
from taskiq_redis import ListRedisScheduleSource

source = ListRedisScheduleSource(url="redis://localhost:6379/0")

@broker.task
async def my_task():
    pass

# This creates schedule:data:{id} but NOT schedule:interval or similar
schedule = await my_task.schedule_by_interval(
    source=source,
    interval=timedelta(seconds=300),
)

# Returns empty list - schedule is lost
schedules = await source.get_schedules()  # []

# Convert interval to cron expression
# 300 seconds = */5 * * * *
schedule = await my_task.schedule_by_cron(
    source=source,
    cron="*/5 * * * *",
)