45

Airflowを使用してバッチ ジョブをスケジュールしています。毎晩実行する 1 つの DAG (A) と、1 か月に 1 回実行する別の DAG (B) があります。B は、A が正常に完了したことに依存します。ただし、B は実行に時間がかかるため、別の DAG に保持して、より適切な SLA レポートを作成できるようにしたいと考えています。

同じ日に DAG A の正常な実行に依存して DAG B を実行するにはどうすればよいですか?

4

3 に答える 3

50

この動作は、ExternalTask​​Sensor という演算子を使用して実現できます。DAG(B) のタスク (B1) がスケジュールされ、DAG(A) のタスク (A2) の成功を待ちます

外部タスク センサーのドキュメント

于 2016-06-25T12:25:16.610 に答える