Два Другие задачи Доля Результат первой задачи

Question

Например:

(task_a.s() | task_b.s()) and (task_a.s() | task_c.s()) 

task_b and task_c share the result of task_a. 

• Как я могу только вычислить task_a только один раз?
• Могу ли я использовать Workflows для решения этого вопроса?

Answer 1

Используйте переменные для хранения вычисленных значений и использования переменных в условии.

ta = task_a.s() 
tb = task_b.s() 
tc = task_c.s() 
if (ta | tb) and (ta | tc) 

Answer 2

Вы можете использовать рабочий сельдерея, используя group примитивно:

Учитывая ваше приложение сельдерея определена и названа приложение, вам придется создать новую задачу, позволяющую сделать and операцию

from celery import group 

@task 
def merge_results(results) 
    return all(results) 

Затем рабочий процесс будет:

(ta.s() | group(tb.s(), tc.s()) | merge_results.s()).apply_async().get()