Моя проблема - я пытаюсь запустить параллельные вызовы с celery 4.4.0rc4
и redis 3.3.8
. в то время как я выполняю apply_async
на group
рабочих местах, я не получаю никакого ответа от сельдерея. Он ждет вечно в консоли сельдерея, но без повторного выполнения серверных задач. Проблема с Redis Backend?
new_list = []
for new_laptop in laptops_list:
new_list.append(async_call.s(new_laptop))
result = group(new_list).apply_async()
result.join()
Я просто возвращаю целочисленное значение из функции async_call
в файле сельдерея.