This document describes an older version of Celery (2.1). For the latest stable version please go here.

Worker Controller Threads - celery.worker.controllers

Worker Controller Threads

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

Thread continuously sending tasks in the queue to the pool.

ready_queue

The task queue, a Queue.Queue instance.

callback

The callback used to process tasks retrieved from the ready_queue.

move()

run()

stop()

Gracefully shutdown the thread.