安排持续气流 DAG 运行
Schedule a continually airflow DAG run
有没有办法让 运行 airflow DAG 循环?
当尝试创建一个循环(将最后一个组件连接到最后一个组件的上游)时,我得到 "Cycle detected in DAG. Faulty task: ..."
通常,我有 3 个 BashOperator 组件的短流程,我想连续 运行(没有从最后一个组件到第一个组件的任何输入输出传递)。
谢谢!
您应该能够在最后一个任务完成后使用 TriggerDagRunOperator 重新运行 DAG。把它放在最后一个运算符之后,让它触发同一个 DAG。
有没有办法让 运行 airflow DAG 循环? 当尝试创建一个循环(将最后一个组件连接到最后一个组件的上游)时,我得到 "Cycle detected in DAG. Faulty task: ..." 通常,我有 3 个 BashOperator 组件的短流程,我想连续 运行(没有从最后一个组件到第一个组件的任何输入输出传递)。 谢谢!
您应该能够在最后一个任务完成后使用 TriggerDagRunOperator 重新运行 DAG。把它放在最后一个运算符之后,让它触发同一个 DAG。