24

私の DAG ファイルでは、失敗した場合に Slack をポストする on_failure_callback() 関数を定義しました。

DAG の各オペレーターに対して次のように指定すると、うまく機能します: on_failure_callback=on_failure_callback()

すべてのオペレーターへのディスパッチを自動化する方法はありますか (たとえば、default_args または DAG オブジェクトを介して)。

4

2 に答える 2