Timer - kombu.async.timer

kombu.async.timer

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=<UTC>)

Table Of Contents

Previous topic

Semaphores - kombu.async.semaphore

Next topic

kombu.transport

This Page