celery.worker.components

• celery.worker.components

celery.worker.components

Default worker bootsteps.

class celery.worker.components.Timer(parent, ***kwargs*)[源代码]

This step initializes the internal timer used by the worker.

• create(w)[源代码]
• name = u’celery.worker.components.Timer’
• on_timer_error(exc)[源代码]
• on_timer_tick(delay)[源代码]
• requires = ()

class celery.worker.components.Hub(w, ***kwargs*)[源代码]

• create(w)[源代码]
• include_if(w)[源代码]
• name = u’celery.worker.components.Hub’
• requires = (step:celery.worker.components.Timer{()},)
• start(w)[源代码]
• stop(w)[源代码]
• terminate(w)[源代码]

class celery.worker.components.Queues(parent, ***kwargs*)[源代码]

This bootstep initializes the internal queues used by the worker.

• create(w)[源代码]
• 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*)[源代码]

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

• close(w)[源代码]
• create(w, semaphore=None, max_restarts=None)[源代码]
• info(w)[源代码]
• name = u’celery.worker.components.Pool’
• register_with_event_loop(w, hub)[源代码]
• requires = (step:celery.worker.components.Queues{(step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)},)
• terminate(w)[源代码]

class celery.worker.components.Beat(w, beat=False, ***kwargs*)[源代码]

Step used to embed a beat process.

This will only be enabled if the beat argument is set.

• conditional = True
• create(w)[源代码]
• label = ‘Beat’
• name = u’celery.worker.components.Beat’
• requires = ()

class celery.worker.components.StateDB(w, ***kwargs*)[源代码]

This bootstep sets up the workers state db if enabled.

• create(w)[源代码]
• name = u’celery.worker.components.StateDB’
• requires = ()

class celery.worker.components.Consumer(parent, ***kwargs*)[源代码]

• create(w)[源代码]
• last = True
• name = u’celery.worker.components.Consumer’
• requires = ()