Можно ли динамически управлять числом воркеров в Celery во время выполнения задач?

В Celery число воркеров (worker processes) обычно задаётся при запуске через команду, например:

celery -A proj worker --concurrency=4

Во время выполнения задач динамически изменить количество воркеров напрямую средствами Celery нельзя. Для изменения числа воркеров нужно запускать или останавливать отдельные процессы воркеров.

Однако можно управлять нагрузкой внутри воркера, например, с помощью параметров --autoscale, который позволяет воркеру автоматически масштабировать количество активных потоков в пределах заданных значений:

celery -A proj worker --autoscale=10,3

Это означает, что воркер будет автоматически увеличивать или уменьшать количество потоков от 3 до 10 в зависимости от нагрузки.

Для изменения общего числа воркеров (процессов) обычно используют инструменты управления процессами (systemd, supervisord, Kubernetes и т.п.), перезапуская или создавая новые воркеры.