Timer scheduling Python callbacks.
-
class kombu.async.timer.Entry(fun, args=None, kwargs=None)
-
args
-
cancel()
-
cancelled
-
fun
-
kwargs
-
tref
-
class kombu.async.timer.Timer(max_interval=None, on_error=None, **kwargs)
ETA scheduler.
-
class Entry(fun, args=None, kwargs=None)
-
args
-
cancel()
-
cancelled
-
fun
-
kwargs
-
tref
-
Timer.apply_entry(entry)
-
Timer.call_after(secs, fun, args=(), kwargs={}, priority=0)
-
Timer.call_at(eta, fun, args=(), kwargs={}, priority=0)
-
Timer.call_repeatedly(secs, fun, args=(), kwargs={}, priority=0)
-
Timer.cancel(tref)
-
Timer.clear()
-
Timer.enter_after(secs, entry, priority=0, time=<built-in function time>)
-
Timer.enter_at(entry, eta=None, priority=0, time=<built-in function time>)
Enter function into the scheduler.
Parameters: |
- entry – Item to enter.
- eta – Scheduled time as a datetime.datetime object.
- priority – Unused.
|
-
Timer.handle_error(exc_info)
-
Timer.on_error = None
-
Timer.queue
Snapshot of underlying datastructure.
-
Timer.schedule
-
Timer.stop()
-
kombu.async.timer.to_timestamp(d, default_timezone=None)