Celery: ограничения параллелизма для каждой задачи (количество рабочих на задачу)?

Можно ли установить параллелизм (количество одновременных рабочих) на уровне задачи в Celery ? Я ищу что-то более детализированное, например CELERYD_CONCURRENCY (которое устанавливает параллелизм для всего демона).

Сценарий использования: у меня есть один celerlyd, выполняющий разные типы задач с очень разные характеристики производительности - некоторые из них быстрые, некоторые очень медленные. Для некоторых я хотел бы сделать столько, сколько смогу, как можно быстрее, для других я хотел бы убедиться, что в любой момент времени работает только один экземпляр (т. е. одновременность 1).

17
задан Parand 6 February 2012 в 21:41
поделиться