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

celery.utils.timer2

Scheduler for Python functions.

Note

This is used for the thread-based worker only, not for amqp/redis/sqs/qpid where kombu.async.timer is used.

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

Schedule Entry.

args

cancel()

canceled

cancelled

fun

kwargs

tref

celery.utils.timer2.Schedule

alias of Timer

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

Timer thread.

Note

This is only used for transports not supporting AsyncIO.

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

Schedule Entry.

args

cancel()

canceled

cancelled

fun

kwargs

tref

Schedule

alias of Timer

call_after(*args, **kwargs)

call_at(*args, **kwargs)

call_repeatedly(*args, **kwargs)

cancel(tref)

clear()

empty()

ensure_started()

enter(entry, eta, priority=None)

enter_after(*args, **kwargs)

exit_after(secs, priority=10)

next()

on_tick = None

queue

run()

running = False

stop()

celery.utils.timer2.to_timestamp(d, default_timezone=<UTC>, time=<built-in function monotonic>)

Convert datetime to timestamp.

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