Я создаю DAG с воздушным потоком с несколькими узлами PythonOperator. Один из них возвращает значение, которое позже будет использоваться в качестве параметра другого оператора. Но как я могу сохранить и получить доступ к этому возвращенному значению?
Например: у меня есть следующие функции
def sum(a, b):
return a + b
def compare(c, d):
return c > d
и следующий знак:
sum = PythonOperator(
task_id = 'sum',
python_callable = sum,
op_args = [a, b],
dag = dag
)
compare = PythonOperator(
task_id = 'compare',
python_callable = compare,
op_args = [{VALUE}, c]
dag = dag
)
sum >> compare
Я хочу {VALUE} будет значением, возвращаемым при выполнении узла суммы. Как я могу хранить и получить к нему доступ?