This document describes the current stable version of Kombu (4.0). For development docs, go here.

Timer - kombu.async.timer

Timer scheduling Python callbacks.

class kombu.async.timer.Entry(fun, args=None, kwargs=None)

Schedule Entry.

args

cancel()

canceled

cancelled

fun

kwargs

tref

class kombu.async.timer.Timer(max_interval=None, on_error=None, **kwargs)

Async timer implementation.

class Entry(fun, args=None, kwargs=None)

Schedule Entry.

args

cancel()

canceled

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=<function _monotonic>)

Timer.enter_at(entry, eta=None, priority=0, time=<function _monotonic>)

Enter function into the scheduler.

Parameters:

• entry (Entry) – Item to enter.
• eta (datetime.datetime) – Scheduled time.
• priority (int) – 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>, time=<function _monotonic>)

Convert datetime to timestamp.

If d’ is already a timestamp, then that will be used.