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

celery.worker.autoscale

class celery.worker.autoscale.Autoscaler(pool, max_concurrency, min_concurrency=0, keepalive=30, logger=None)

processes

qty

run()

scale()

scale_down(n)

scale_up(n)

stop()