Воздушный поток 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}[/b] in DAG [b]{context['dag'].dag_id}[/b] 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