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

celery.worker.mediator

Worker Controller Threads

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

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

callback = None

Callback called when a task is obtained.

move()
ready_queue = None

The task queue, a Queue instance.

run()

Move tasks forver or until stop() is called.

stop()

Gracefully shutdown the thread.

Previous topic

celery.worker.job

Next topic

celery.worker.buckets

This Page