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

celery.worker.pidbox

class celery.worker.pidbox.Pidbox(c)[source]
consumer = None
on_message(body, message)[source]
on_stop()[source]
reset()[source]

Sets up the process mailbox.

shutdown(c)[source]
start(c)[source]
stop(c)[source]
class celery.worker.pidbox.gPidbox(c)[source]
loop(c)[source]
on_stop()[source]
reset()[source]
start(c)[source]