2017-12-24 32 views
2

空気流DAGをループ内で実行する方法はありますか? サイクルを作成しようとすると(最後のコンポーネントを最後のコンポーネントの上流に接続している)、「DAGでサイクルが検出されました」というエラーが発生しました。 一般的に、私は3つのBashOperatorコンポーネント(最後のコンポーネントから最初のコンポーネントへの入出力出力は一切ありません)。 ありがとう!空気流DAGを継続的に実行する

答えて

1

最後のタスクが完了した後で、TriggerDagRunOperatorを使用してDAGを再実行できるはずです。最後の演算子の後に置いて、同じDAGをトリガーさせるだけです。

関連する問題