This document describes the current stable version of Celery (3.1). For development docs, go here.
celery.worker.components¶
celery.worker.components¶
Default worker bootsteps.
-
class
celery.worker.components.
Timer
(parent, **kwargs)[source]¶ This step initializes the internal timer used by the worker.
-
name
= u'celery.worker.components.Timer'¶
-
-
class
celery.worker.components.
Hub
(w, **kwargs)[source]¶ -
-
name
= u'celery.worker.components.Hub'¶
-
requires
= (step:celery.worker.components.Timer{()},)¶
-
-
class
celery.worker.components.
Queues
(parent, **kwargs)[source]¶ This bootstep initializes the internal queues used by the worker.
-
label
= 'Queues (intra)'¶
-
name
= u'celery.worker.components.Queues'¶
-
requires
= (step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)¶
-
-
class
celery.worker.components.
Pool
(w, autoscale=None, autoreload=None, no_execv=False, optimization=None, **kwargs)[source]¶ Bootstep managing the worker pool.
Describes how to initialize the worker pool, and starts and stops the pool during worker startup/shutdown.
Adds attributes:
- autoscale
- pool
- max_concurrency
- min_concurrency
-
name
= u'celery.worker.components.Pool'¶
-
requires
= (step:celery.worker.components.Queues{(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.
This will only be enabled if the
beat
argument is set.-
conditional
= True¶
-
label
= 'Beat'¶
-
name
= u'celery.worker.components.Beat'¶
-