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

celery.worker.mediator

class celery.worker.mediator.Mediator(ready_queue, callback, logger=None, app=None)

Thread continuously moving tasks from the ready queue onto the pool.

callback = None

Callback called when a task is obtained.

move()

ready_queue = None

The task queue, a Queue instance.

run()

Move tasks until stop() is called.

stop()

Gracefully shutdown the thread.