Динамически добавлять / удалять потоки в рабочий пул в сельдерее

Как добавить больше потоков (и удалить потоки) ) в текущий пул многопроцессорной обработки из задачи (т.е. celeryd был запущен с CELERYD_CONCURRENCY = 10, но я хочу на лету изменить его на CELERYD_CONCURRENCY = 15)?

Существует функция, называемая celery. concurrency.processes.TaskPool.Pool.grow , но я понятия не имею, как вызвать это из запущенной задачи и правильная ли это функция для этого.

7
задан Leonth 5 August 2011 в 12:29
поделиться