Airflowで実行中のDAGを安全にストップさせる方法

Question

Airflowを使ってバッチジョブをスケジューリングしています。
しかし、開発段階で試す際に、誤って本番同等データ量でDAGを実行させると、なかなか終わらず困るので、
安全に中断させる方法が知りたいです。

以前、runningのTaskをクリックしてClearを押下したところ、DAGの実行は止まったようなのですが、
DBにその時の実行情報？が残っているようで、次回実行時にその情報を基にTaskを実行しようとしてエラーが起きるという現象に陥りました。

DBの情報の整合性を保ちつつDAGを中断することはできないのでしょうか？

Answer 1

Airflowのことはよく知らないですが、
一般的には「冪等性」を確保できるように設計・実装すると良いと思います。

参考