У меня есть отметка с заданием 1 и заданием 2,
задание 2 касается оператора электронной почты, который запускается при сбое задания 1,
это мой код:
t1 = BashOperator(
task_id="example error",
bash_command="xxxxx",
dag=dag)
t2 = EmailOperator(
task_id="send_mail",
trigger_rule='one_failed',
to='receivers@mail.com',
subject='Job error',
html_content='<p> error log : {output} <p>',
dag=dag)
t1 >> t2
с примером кода ошибки в task1, я получу сообщение об ошибке в веб-интерфейсе пользователя
[2020-04-29 20:32:07,348] {bash_operator.py:122} INFO - Output:
[2020-04-29 20:32:07,351] {bash_operator.py:126} INFO - /tmp/airflowtmppo4dyt11/failm79eacvd: line 1: xxx: command not found
[2020-04-29 20:32:07,351] {bash_operator.py:128} INFO - Command exited with return code 127
[2020-04-29 20:32:07,359] {taskinstance.py:1145} ERROR - Bash command failed
Моя цель - включить этот выходной журнал ошибок в тело оператора электронной почты, есть ли способ получить этот журнал ошибок?