This document is for Celery's development version, which can be significantly different from previous releases. Get old docs here: 2.5.

celery.utils.timer2

timer2

Scheduler for Python functions.

copyright:

3. 2009 - 2012 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

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)