分支联接运算符

2024-09-29 23:30:58 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试加入气流中的分支操作符

我这样做:

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

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

current airflow dag

我如何得到这个:

desired airflow dag


Tags: 关系分支模式气流op5op2op4op1
2条回答

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

第二:您可以尝试使用chain function。如果您查看关系构建器部分中的最后一个示例,那么这应该就是您试图实现的目标,对吗

第三:可以使用airflow show_dag轻松地可视化dag

你能说清楚点吗?我试着使用你的链函数,我可以做你想做的enter image description here

相关问题 更多 >

    热门问题