Skip to main content

​
Overview

Distributed task scheduler using Redis for background jobs and scheduled agent operations. Benefits: Distributed, persistent, scalable, fast in-memory performance

​
Features

Delayed Execution - Schedule tasks to run later
Recurring Jobs - Run tasks at intervals
Cron Scheduling - Run tasks at specific times
Priority Queues - Process high-priority tasks first

​
Use Cases

  • Scheduled agent health checks
  • Periodic skill updates
  • Automatic context cleanup
  • Background artifact processing
  • Maintenance tasks (cleanup, backups)

​
Implementation

from bindu.scheduler import RedisScheduler

scheduler = RedisScheduler(
    redis_url="redis://localhost:6379",
    max_workers=10
)

# Schedule delayed task
scheduler.schedule(
    task_id="cleanup",
    delay=timedelta(minutes=5),
    handler=cleanup_old_artifacts
)

# Schedule recurring job
scheduler.schedule_recurring(
    job_id="health-check",
    interval=timedelta(hours=1),
    handler=check_agent_health
)

​
Status

🚀 In Progress - Core scheduler implementation and Redis integration

​
What’s Next

  • Discuss - Share your scheduling needs on Discord