这就是我想要的,但我不知道如何在气流中实现这一点,因为这两项任务都在执行中
总结如下:
option_1 -> complete
或者option_2 -> Do_x, Do_y -> complete
我应该如何构造这个?我的当前代码是:
(t1 >> t2 >> option_1 >> complete)
(t1 >> t2 >> option_2 >> do_x >> do_y >> complete)
在这种情况下,t2是一个分支操作符
我还尝试了... [option_1, option_2] ...
的语法,但我需要一个完全独立的路径来执行,而不仅仅是切换一个任务
代码中的依赖关系对于分支是正确的。确保
BranchPythonOperator
根据所需的逻辑,在分支开始时返回任务的task_id
。更多关于BranchPythonOperator
here的信息。最后一个重要注意事项与“完成”任务有关。由于分支聚合在“complete”任务上,请确保将trigger_rule
设置为“none_failed”(您也可以使用TriggerRule
类常量),以便不会跳过该任务快速代码测试供您参考:
相关问题 更多 >
编程相关推荐