failure_function for airflow email reporting

failure_report.py

from airflow.operators.email_operator import EmailOperator


def report_failure(context):
    subject = 'Airflow critical: {{ti}}'
    html_content = (
        'Try {{try_number}} out of {{max_tries + 1}}<br>'
        'Exception:<br>{{exception_html}}<br>'
        'Log: <a href="{{ti.log_url}}">Link</a><br>'
        'Host: {{ti.hostname}}<br>'
        'Log file: {{ti.log_filepath}}<br>'
        'Mark success: <a href="{{ti.mark_success_url}}">Link</a><br>'
    )
    """Send custom email alerts."""
    return EmailOperator(
        task_id='report_email_failure',
        to='your-destination-email@email.com',
        subject=subject,
        html_content=html_content,
    ).execute(context)