Worker Scheduler - celery.worker.scheduler¶

class celery.worker.scheduler.Scheduler(ready_queue, logger=None, max_interval=2)¶

ETA scheduler.

Parameters:	ready_queue – Queue to move items ready for processing. max_interval – Maximum sleep interval between iterations. Default is 2 seconds.

clear()¶

empty()¶

Is the schedule empty?

enter(item, eta=None, priority=0, callback=None)¶

Enter item into the scheduler.

Parameters:	item – Item to enter. eta – Scheduled time as a datetime.datetime object. priority – Unused. callback – Callback to call when the item is scheduled. This callback takes no arguments.

info()¶

queue¶