Можно ли повторно использовать зависимости задачи воздушного потока? ⇐ Python

[Anonymous]

У меня есть серия даг воздушного потока, которые повторно используют некоторые зависимости задачи.
Например < /p>

Код: Выделить всё

DAG 1:
T1 >> T2

DAG 2:
T1 >> T2 >> T3

DAG 3:
T1 >> T2 >> T3 >> [T4, T5, T6] >> T7
< /code>
Я хотел бы сохранить зависимости от DAG 1 (который в этой модели используется любым другим DAG) и повторно используйте их при объявлении зависимостей для других DAG, например, так: < /p>
def dag_1_dependencies():
T1 >> T2

DAG 2:
dag_1_dependencies() >> T3

DAG 3:
dag_1_dependencies() >> T3 >> [T4, T5, T6] >> T7
< /code>
Проблема в том, что сами зависимости не являются значением, поэтому я не могу вернуть их методом. Вызов DAG_1_Dependencies () 

ничего не делает. Есть ли способ обойти это?

Подробнее здесь: https://stackoverflow.com/questions/794 ... be-re-used