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

celery.concurrency.gevent

Gevent execution pool.

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

GEvent Pool.

class Timer(*args, **kwargs)
clear()
queue
grow(n=1)[source]
is_green = True
num_processes
on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, apply_target=<function apply_target>, **_)[source]
on_start()[source]
on_stop()[source]
shrink(n=1)[source]
signal_safe = False
task_join_will_block = False