Хук post_execution для DAG в Airflow

Question

Поиск способа выполнения фрагмента кода после завершения определенной группы обеспечения доступности баз данных (независимо от успеха или неудачи)

Просматривая исходный код, я смог расширить BaseOperator и определить хук post_execution для операторов. Есть ли что-то похожее для DAG?

Edit: Моя конечная цель - опубликовать состояние группы доступности базы данных в очереди SQS.

Answer 1

Один из вариантов - использовать правила триггера : возьмите оператор, которому нужно выполнить ваш фрагмент кода, и убедитесь, что это последний оператор в вашей группе обеспечения доступности баз данных, затем установите trigger_rule на * 1004.*.

Таким образом, оператор будет выполняться независимо от состояния успеха предыдущих операторов.