This document describes an older version of Celery (2.2). For the latest stable version please go here.

celery.concurrency.evlet† (experimental)

class celery.concurrency.evlet.Schedule(*args, **kwargs)
clear()
enter(entry, eta=None, priority=0)
queue
class celery.concurrency.evlet.TaskPool(*args, **kwargs)
class Timer(schedule=None, on_error=None, on_tick=None, **kwargs)
class Schedule(*args, **kwargs)
clear()
enter(entry, eta=None, priority=0)
queue
TaskPool.Timer.ensure_started()
TaskPool.Timer.start()
TaskPool.Timer.stop()
TaskPool.is_green = True
TaskPool.on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, **_)
TaskPool.on_start()
TaskPool.on_stop()
TaskPool.signal_safe = False
class celery.concurrency.evlet.Timer(schedule=None, on_error=None, on_tick=None, **kwargs)
class Schedule(*args, **kwargs)
clear()
enter(entry, eta=None, priority=0)
queue
Timer.ensure_started()
Timer.start()
Timer.stop()
celery.concurrency.evlet.apply_target(target, args=(), kwargs={}, callback=None, accept_callback=None, getpid=None)

Previous topic

celery.concurrency.processes.pool

Next topic

celery.concurrency.evg† (experimental)

This Page