Airflow - 分支连接运算符

Question

我正在尝试加入 Airflow 中的分支运算符

我这样做了：

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

它给出了这样一个模式，其中包含 op2、op3、op4 和 op8 之间的关系。

我如何得到这个：

Answer 1

首先：您能否更具体地说明您用于设置任务之间关系的确切代码？

其次：您可以尝试使用 chain function。如果您查看关系建立者部分中的最后一个示例，那应该就是您要实现的目标吧？

第三：你可以使用airflow show_dag轻松可视化你的dag。

Answer 2

你能说清楚点吗？我试过使用你的链函数，我可以做你想做的。