This document describes an older version of Celery (2.1).
For the latest stable version please
go here.
timer2 - celery.utils.timer2
timer2 - Scheduler for Python functions.
-
class celery.utils.timer2.Entry(fun, args=None, kwargs=None)
-
cancel()
-
cancelled = False
-
class celery.utils.timer2.Schedule(max_interval=2, on_error=None)
ETA scheduler.
-
clear()
-
empty()
Is the schedule empty?
-
enter(entry, eta=None, priority=0)
Enter function into the scheduler.
Parameters: |
- entry – Item to enter.
- eta – Scheduled time as a datetime.datetime object.
- priority – Unused.
|
-
handle_error(exc_info)
-
info()
-
on_error = None
-
queue
-
exception celery.utils.timer2.TimedFunctionFailed
-
class celery.utils.timer2.Timer(schedule=None, on_error=None, on_tick=None, **kwargs)
-
class Entry(fun, args=None, kwargs=None)
-
cancel()
-
cancelled = False
-
Timer.apply_after(msecs, fun, args=(), kwargs={}, priority=0)
-
Timer.apply_at(eta, fun, args=(), kwargs={}, priority=0)
-
Timer.apply_entry(entry)
-
Timer.apply_interval(msecs, fun, args=(), kwargs={}, priority=0)
-
Timer.cancel(tref)
-
Timer.clear()
-
Timer.empty()
-
Timer.ensure_started()
-
Timer.enter(entry, eta, priority=None)
-
Timer.enter_after(msecs, entry, priority=0)
-
Timer.exit_after(msecs, priority=10)
-
Timer.next()
-
Timer.on_tick = None
-
Timer.queue
-
Timer.run()
-
Timer.running = False
-
Timer.stop()
-
celery.utils.timer2.to_timestamp(d)