параллельные задачи по блокировке сельдерея - PullRequest
0 голосов
/ 21 января 2020

У меня есть приложение в Flask, которое загружает процессор. Я бы хотел, чтобы приложение работало параллельно, поэтому я использовал сельдерей. Если задачи запущены, и я не жду, пока они завершатся sh, они работают параллельно. Однако, когда я жду, пока они завершат sh (блок), следующая задача запускается после завершения предыдущей

@myapp.route("/calc")
def calc():
    task = cpu_intensive_task.delay(30)
    result = task.get() # blocking
    return f'result={result}'

Я также пытался запустить много рабочих, но первая задача выполняется на worker1 и только после его завершения второй рабочий получает второе задание

Могу ли я что-то сделать для параллельного выполнения задач?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...