This document describes Celery 2.4. For development docs, go here.

celery.utils.timer2

timer2

Scheduler for Python functions.

copyright:
  1. 2009 - 2011 by Ask Solem.
license:

BSD, see LICENSE for more details.
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
class Timer.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
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)