Джанго сельдерей выполняет только две задачи одновременно?

Question

У меня есть задача сельдерея, как это:

@celery.task
def file_transfer(password, source12, destination):
    result = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', source12, destination], 
                                    stderr=subprocess.PIPE, stdout=subprocess.PIPE).communicate()[0]                             
    return result        

Я позвонил в виде Дьягно.

Пользователь может выбрать более одного файла для копирования в пункт назначения. Например, если пользователь выбирает 4 файла одновременно, сельдерей принимает только 2 задания. В чем дело?

Answer 1

Вы проверили настройки параллелизма вашего работника?

Например, если на двухъядерном компьютере работает только один работник, параллелизм по умолчанию будет равен 2. Это означает, что одновременно могут выполняться только две задачи.

Вы можете изменить этот параметр из командной строки рабочего с помощью переключателя:

 -c N

где N - количество параллельных задач