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


API Reference

Embedded workers for integration tests.

class celery.contrib.testing.worker.TestWorkController(*args, **kwargs)[source]

Worker that can synchronize on being fully started.


Wait for worker to be fully up and running.


Worker must be started within a thread for this to work, or it will block forever.


Callback called when the Consumer blueprint is fully started.

celery.contrib.testing.worker.setup_app_for_worker(app, loglevel, logfile)[source]

Setup the app to be used for starting an embedded worker.

celery.contrib.testing.worker.start_worker(*args, **kwds)[source]

Start embedded worker. – worker instance.