def streams_tasks(scheduler): scheduler.schedule( scheduled_time=datetime.utcnow(), func=groom_redis_precaches, interval=60*60*24, # a day )