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

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   

я назвал в представлении Djagno.

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

Answer 1

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

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

Вы можете изменить эту установку из рабочей командной строки с ключом:

-c N 

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