This document describes the current stable version of Celery (5.2). For development docs, go here.
Embedded workers for integration tests.
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.
setup_app_for_worker(app, loglevel, logfile)¶
Setup the app to be used for starting an embedded worker.
start_worker(app, concurrency=1, pool='solo', loglevel='error', logfile=None, perform_ping_check=True, ping_task_timeout=10.0, shutdown_timeout=10.0, **kwargs)¶
Start embedded worker.
celery.app.worker.Worker – worker instance.