在一个DAG中创建多个子标记

Question

我在main_DAG中有多个任务(它们是子标签):subdag1,subdag2,subdag3。每当我尝试创建这样的流时:

main_DAG>>subdag1>>subdag2>>subdag3

我得到这个错误:

Tried to set relationships between tasks in more than one DAG: dict_values([<DAG: main_DAG, <DAG: main_DAG.subdag2>])

但是当我这样写的时候:

main_DAG>>subdag1>>subdag1>>subdag1

没有得到任何错误。那么，我是否可以在同一个DAG中使用不同的子DAG任务?

Answer 1

你可以这样写

main_dag祝辞祝辞[subdag1, subdag2, subdag3]

这样，一旦main_dag完成，它将触发subdag1,subdag2 &Subdag3一次并行。