安排连续气流DAG运行

Question

有没有一种方法可以使气流DAG循环运行？当尝试创建一个循环（将最后一个组件连接到最后一个组件的上游）时，我收到“在DAG中检测到循环。错误的任务：...”通常，我要运行的BashOperator组件数量很少，只有3个连续（没有从最后一个组件到第一个组件的任何输入-输出传递）。谢谢！

Answer 1

在完成最后一个任务之后，您应该能够使用TriggerDagRunOperator重新运行DAG。只需将其放在最后一个运算符之后，并使其触发相同的DAG。