This document describes the current stable version of Celery (4.4). For development docs, go here.
celery.worker.components
¶
Worker-level Bootsteps.
-
class
celery.worker.components.
Timer
(parent, **kwargs)[source]¶ Timer bootstep.
-
name
= 'celery.worker.components.Timer'¶
-
-
class
celery.worker.components.
Hub
(w, **kwargs)[source]¶ Worker starts the event loop.
-
include_if
(w)[source]¶ Return true if bootstep should be included.
You can define this as an optional predicate that decides whether this step should be created.
-
name
= 'celery.worker.components.Hub'¶
-
requires
= (step:celery.worker.components.Timer{()},)¶
-
-
class
celery.worker.components.
Pool
(w, autoscale=None, **kwargs)[source]¶ Bootstep managing the worker pool.
Describes how to initialize the worker pool, and starts and stops the pool during worker start-up/shutdown.
Adds attributes:
- autoscale
- pool
- max_concurrency
- min_concurrency
-
name
= 'celery.worker.components.Pool'¶
-
requires
= (step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)¶
-
class
celery.worker.components.
Beat
(w, beat=False, **kwargs)[source]¶ Step used to embed a beat process.
Enabled when the
beat
argument is set.-
conditional
= True¶
-
label
= 'Beat'¶
-
name
= 'celery.worker.components.Beat'¶
-