我正在使用Airflow来安排批处理作业.我有一个每晚运行的DAG(A)和每月运行一次的另一个DAG(B). B取决于A已成功完成.但是B需要很长时间才能运行,因此我希望将其保存在单独的DAG中,以便更好地进行SLA报告.

如何在同一天成功运行DAG A,使DAG B运行？

解决方法:

您可以使用名为ExternalTask​​Sensor的运算符来实现此行为.
DAG(B)中的任务(B1)将被安排并等待DAG(A)中的任务(A2)成功

External Task Sensor documentation