celery.worker.autoscale

• celery.worker.autoscale

celery.worker.autoscale

This module implements the internal thread responsible for growing and shrinking the pool according to the current autoscale settings.

The autoscale thread is only enabled if --autoscale has been enabled on the command-line.

class celery.worker.autoscale.Autoscaler(pool, max_concurrency, min_concurrency=0, worker=None, keepalive=30.0, mutex=None)[源代码]

• body()[源代码]
• force_scale_down(n)[源代码]
• force_scale_up(n)[源代码]
• info()[源代码]
• maybe_scale()[源代码]
• processes None[源代码]
• qty None[源代码]
• scale_down(n)[源代码]
• scale_up(n)[源代码]
• update(max=None, min=None)[源代码]

class celery.worker.autoscale.WorkerComponent(w, ***kwargs*)[源代码]

• conditional = True
• create(w)[源代码]
• label = ‘Autoscaler’
• name = u’celery.worker.autoscale.WorkerComponent’
• register_with_event_loop(w, hub)
• requires = (step:celery.worker.components.Pool{(step:celery.worker.components.Queues{(step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)},)},)