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

celery.utils.timer2

timer2

Scheduler for Python functions.

class celery.utils.timer2.Entry(fun, args=None, kwargs=None)

args

cancel()

cancelled

fun

kwargs

tref

class celery.utils.timer2.Schedule(max_interval=None, on_error=None, **kwargs)

ETA scheduler.

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

args

cancel()

cancelled

fun

kwargs

tref

Schedule.apply_after(msecs, fun, args=(), kwargs={}, priority=0)

Schedule.apply_at(eta, fun, args=(), kwargs={}, priority=0)

Schedule.apply_entry(entry)

Schedule.apply_interval(msecs, fun, args=(), kwargs={}, priority=0)

Schedule.cancel(tref)

Schedule.clear()

Schedule.empty()

Is the schedule empty?

Schedule.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.

Schedule.enter_after(msecs, entry, priority=0, time=<built-in function time>)

Schedule.handle_error(exc_info)

Schedule.info()

Schedule.on_error = None

Schedule.queue

Snapshot of underlying datastructure.

Schedule.schedule

Schedule.stop()

class celery.utils.timer2.Timer(schedule=None, on_error=None, on_tick=None, max_interval=None, **kwargs)

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

args

cancel()

cancelled

fun

kwargs

tref

class Timer.Schedule(max_interval=None, on_error=None, **kwargs)

ETA scheduler.

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

args

cancel()

cancelled

fun

kwargs

tref

Timer.Schedule.apply_after(msecs, fun, args=(), kwargs={}, priority=0)

Timer.Schedule.apply_at(eta, fun, args=(), kwargs={}, priority=0)

Timer.Schedule.apply_entry(entry)

Timer.Schedule.apply_interval(msecs, fun, args=(), kwargs={}, priority=0)

Timer.Schedule.cancel(tref)

Timer.Schedule.clear()

Timer.Schedule.empty()

Is the schedule empty?

Timer.Schedule.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.

Timer.Schedule.enter_after(msecs, entry, priority=0, time=<built-in function time>)

Timer.Schedule.handle_error(exc_info)

Timer.Schedule.info()

Timer.Schedule.on_error = None

Timer.Schedule.queue

Snapshot of underlying datastructure.

Timer.Schedule.schedule

Timer.Schedule.stop()

Timer.apply_after(*args, **kwargs)

Timer.apply_at(*args, **kwargs)

Timer.apply_interval(*args, **kwargs)

Timer.cancel(tref)

Timer.clear()

Timer.empty()

Timer.ensure_started()

Timer.enter(entry, eta, priority=None)

Timer.enter_after(*args, **kwargs)

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, default_timezone=tzfile('/usr/share/zoneinfo/UTC'))