Veja a subclasse da classe AutoScaler
e defina a variável min_concurrency
em código%. A min_concurrency padrão de 0 está impedindo que o AutoScaler padrão seja reduzido.
Eu não testei esta classe (meus nós de teste do Celery estão desligados), mas algo como o seguinte deve funcionar:
from celery.worker.autoscale import Autoscaler
class MinIdleAutoscaler(Autoscaler):
def __init__(self,pool, max_concurrency, min_concurrency=10, keepalive=30, logger=None):
Autoscaler.__init__(self,pool,max_concurrency,min_concurrency,keepalive,logger)
Você pode então dizer ao Celery para usar essa classe definindo __init__
em seu aipo config.