This document describes an older version of Celery (2.5). For the latest stable version please go here.

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.

copyright:
  1. 2009 - 2012 by Ask Solem.
license:

BSD, see LICENSE for more details.

class celery.worker.autoscale.Autoscaler(pool, max_concurrency, min_concurrency=0, keepalive=30, logger=None)
body()
force_scale_down(n)
force_scale_up(n)
info()
processes
qty
scale()
scale_down(n)
scale_up(n)
update(max=None, min=None)
class celery.worker.autoscale.WorkerComponent(w, **kwargs)
create(w)
name = 'autoscaler'
namespace = 'worker'
requires = ('pool',)

Previous topic

celery.worker.autoreload

Next topic

celery.concurrency

This Page