私の DAG ファイルでは、失敗した場合に Slack をポストする on_failure_callback() 関数を定義しました。
DAG の各オペレーターに対して次のように指定すると、うまく機能します: on_failure_callback=on_failure_callback()
すべてのオペレーターへのディスパッチを自動化する方法はありますか (たとえば、default_args または DAG オブジェクトを介して)。
私の DAG ファイルでは、失敗した場合に Slack をポストする on_failure_callback() 関数を定義しました。
DAG の各オペレーターに対して次のように指定すると、うまく機能します: on_failure_callback=on_failure_callback()
すべてのオペレーターへのディスパッチを自動化する方法はありますか (たとえば、default_args または DAG オブジェクトを介して)。