【发布时间】:2021-11-30 06:49:54
【问题描述】:
我不想使用 Slack。我只是在args 中使用自定义通知(on_failure_callback) 功能作为我的邮件功能。我用过
def task_my_alert(context):
task_id=context['task'].task_id
dag_run = context.get('dag_run')
log_url=context.get('task_instance').log_url
default_html_content = (
'Log: <a href={log_url}>Link</a><br>'
'Getback:<a href={MY_AIRFLOW_IP_ADDRESS}>CLICK FOR BACK</a><br>'
)
sub=f"dag has errors"
send_email(to='my@email.com', subject=sub , html_content=default_html_content)
但我的电子邮件中的链接[a href] 不适合我。即:我的电子邮件中没有链接。需要做出哪些改变?
【问题讨论】:
标签: airflow href airflow-api