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

celery.concurrency.gevent† (experimental)

celery.concurrency.gevent

gevent pool implementation.

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

class Timer(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)

class Schedule(*args, **kwargs)

clear()

queue

ensure_started()

start()

stop()

grow(n=1)

is_green = True

num_processes

on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, timeout=None, timeout_callback=None, **_)

on_start()

on_stop()

shrink(n=1)

signal_safe = False

task_join_will_block = False