Есть ли способ передать текст ошибки сбойной задачи Airflow в другую задачу? - PullRequest
0 голосов
/ 05 марта 2019

У меня определена группа доступности базы данных, которая содержит ряд задач, последняя из которых запускается только в случае сбоя любой из предыдущих задач.Эта задача просто отправляет в канал Slack сообщение о том, что DAG запускает обнаруженные ошибки.

Что бы мне действительно хотелось, чтобы сообщение, отправленное в канал Slack, содержало фактическую ошибку, зарегистрированную в журналах задач, для немедленного предоставленияконтекст к ошибке и, возможно, избавить Ops от необходимости копаться в журналах.

Возможно ли это вообще?

...