如何设置气流中DAG之间的依赖关系？

Question

我正在使用Airflow安排批处理作业。我有一个DAG（A）每晚运行，另一个DAG（B）每月运行一次。B取决于A是否成功完成。但是B需要很长时间才能运行，所以我希望将它保存在单独的DAG中，以便更好地进行SLA报告。

如何使运行DAG B依赖于在同一天成功运行DAG a？

Answer 1

可以使用名为ExternalTaskSensor的运算符实现此行为。 您在DAG（B）中的任务（B1）将被安排，并等待DAG（a）中的任务（A2）成功

External Task Sensor documentation

Answer 2

看起来还可以使用TriggerDagRunOperator，并且可以使用可调用的python来添加一些逻辑。如前所述：https://www.linkedin.com/pulse/airflow-lesson-1-triggerdagrunoperator-siddharth-anand