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

celery.concurrency.eventlet

Eventlet execution pool.

class celery.concurrency.eventlet.TaskPool(*args, **kwargs)[source]

Eventlet Task Pool.

class Timer(*args, **kwargs)

Eventlet Timer.

cancel(tref)
clear()
queue
TaskPool.grow(n=1)[source]
TaskPool.is_green = True
TaskPool.on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, **_)[source]
TaskPool.on_start()[source]
TaskPool.on_stop()[source]
TaskPool.shrink(n=1)[source]
TaskPool.signal_safe = False
TaskPool.task_join_will_block = False