This document describes the current stable version of Celery (4.0). For development docs, go here.
celery.utils.timer2
¶
Scheduler for Python functions.
Note
This is used for the thread-based worker only,
not for amqp/redis/sqs/qpid where kombu.async.timer
is used.
-
class
celery.utils.timer2.
Entry
(fun, args=None, kwargs=None)[source]¶ Schedule Entry.
-
args
¶
-
canceled
¶
-
cancelled
¶
-
fun
¶
-
kwargs
¶
-
tref
¶
-
-
class
celery.utils.timer2.
Timer
(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)[source]¶ Timer thread.
Note
This is only used for transports not supporting AsyncIO.
-
class
Entry
(fun, args=None, kwargs=None)¶ Schedule Entry.
-
args
¶
-
cancel
()¶
-
canceled
¶
-
cancelled
¶
-
fun
¶
-
kwargs
¶
-
tref
¶
-
-
Timer.
next
()¶
-
Timer.
on_tick
= None¶
-
Timer.
queue
¶
-
Timer.
running
= False¶
-
class