Я пытаюсь присоединиться к операторам ветвления в Airflow
Я сделал это:
op1>>[op2,op3,op4] op2>>op5 op3>>op6 op4>>op7 [op5,op6,op7]>>op8
Это дает такую схему с отношениями между op2, op3, op4 и op8.
Как мне это получить:
Вы можете быть более ясным? Я пытался использовать вашу цепочку, и я могу делать то, что вы хотели.
Прежде всего: можете ли вы указать более точный c точный код, который вы используете для установки отношений между задачами?
Во-вторых: вы можете попробовать использовать цепную функцию . Если вы посмотрите на последний пример в разделе построителей отношений, это должно быть примерно то, что вы пытаетесь достичь правильно?
В-третьих: вы можете использовать airflow show_dag , чтобы легко визуализировать ваши даг.