сигны тасок переданные в аргументе chain метода send_task выполняются не в том порядке, в котором они находятся в списке?
Пример:
app.send_task('root_task', queue='my_queue', chain=[task_2_sign, task_3_sign])
Первой выполняется рутовая таска, но потом, вместо task_2 стартует task_3, а только в конце task_2...
А че try expect - не помогает?)
В смысле? Это же на уровне воркера происходит.
Опечатался он, что ты сразу пристал except
Тут похожую тему разбирали - может поможет https://github.com/CCA-Public/scope/issues/127
чейнить можно множество тасок на одну. Думаю в твоем случае чтобы task_3 был строго за task_2 тебе надо его самого передать в чейн к второму.
думаю должно быть что-то вроде chain=[task_2_sign.s(link=task_3_sign)]
Я уже переделал вызов на простой chain с apply_async вызовом. Вроде работает.
Обсуждают сегодня