Airflow - операторы ветвления и соединения - PullRequest
1 голос
/ 13 марта 2020

Я пытаюсь присоединиться к операторам ветвления в Airflow

Я сделал это:

op1>>[op2,op3,op4]
op2>>op5
op3>>op6
op4>>op7
[op5,op6,op7]>>op8

Это дает такую ​​схему с отношениями между op2, op3, op4 и op8.

current airflow dag

Как мне это получить:

desired airflow dag

Ответы [ 2 ]

2 голосов
/ 19 марта 2020

Вы можете быть более ясным? Я пытался использовать вашу цепочку, и я могу делать то, что вы хотели. enter image description here

0 голосов
/ 18 марта 2020

Прежде всего: можете ли вы указать более точный c точный код, который вы используете для установки отношений между задачами?

Во-вторых: вы можете попробовать использовать цепную функцию . Если вы посмотрите на последний пример в разделе построителей отношений, это должно быть примерно то, что вы пытаетесь достичь правильно?

В-третьих: вы можете использовать airflow show_dag , чтобы легко визуализировать ваши даг.

...