我的书签
添加书签
移除书签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{()},)},)},)},)
