问题描述
我有一个要求DAG遵循以下条件
-> Task C -> Task D
|
Task A -> Task B -
|
-> Task E -> Task F
任务B具有一个python三元运算符，该运算符决定要在运行时执行的方向/分支，即运行时流将是（任务C，任务D）或（任务E，任务F）
我们如何在luigi任务的require函数下定义它？任何想法或代码片段都将不胜感激。
解决方法
您可以定义dynamic dependency。
我认为在您的示例中，您有一个任务G，该任务将取决于B并基于B的输出产生C和{{1} }或D和E
F
