celery.worker.autoscale

• celery.worker.autoscale

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)[源代码]

• maybe_scale()

• processes None[源代码]

• qty None

• scale_down(n)[源代码]

• scale_up(n)

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

• conditional = True

• create(w)

• label = ‘Autoscaler’

• name = u’celery.worker.autoscale.WorkerComponent’