This document describes Celery 3.0. For development docs, go here.

celery.concurrency.gevent† (experimental)

celery.concurrency.gevent

gevent pool implementation.

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

clear()

queue

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

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

class Schedule(*args, **kwargs)

clear()

queue

TaskPool.Timer.ensure_started()

TaskPool.Timer.start()

TaskPool.Timer.stop()

TaskPool.grow(n=1)

TaskPool.is_green = True

TaskPool.num_processes

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

TaskPool.on_start()

TaskPool.on_stop()

TaskPool.rlimit_safe = False

TaskPool.shrink(n=1)

TaskPool.signal_safe = False

class celery.concurrency.gevent.Timer(schedule=None, on_error=None, on_tick=None, max_interval=None, **kwargs)

class Schedule(*args, **kwargs)

clear()

queue

Timer.ensure_started()

Timer.start()

Timer.stop()

celery.concurrency.gevent.apply_timeout(target, args=(), kwargs={}, callback=None, accept_callback=None, pid=None, timeout=None, timeout_callback=None, **rest)