Воздушный поток on_success_callback ⇐ Python

[Anonymous]

Я пытаюсь выполнить программу, которая отправляет уведомление по электронной почте об успехе, используя on_success_callback. Я добавил следующую функцию в начало скрипта. Задание успешно завершается в Airflow, но уведомление об успехе по электронной почте не получено.Что-то не хватает в функции?
from airflow.utils.email import send_email

def email_success(context):
subject = f"Job {context['task_instance_key_str']} Completed"
html_content = f"""
The task {context['task_instance'].task_id} in DAG {context['dag'].dag_id} completed successfully.
"""
send_email(to=['xyz@xyz.com'], subject=subject, html_content=html_content)

default_args = {
'owner': 'ABC',
'depends_on_past': False,
'email': ['xyz@xyz.com'],
'email_on_failure': True,
'on_success_callback': email_success,
'start_date': days_ago(1),
'schedule': '@daily'
}


Подробнее здесь: https://stackoverflow.com/questions/793 ... s-callback