From ad3fa4999298904ac6285cb05069031cd5ac76e3 Mon Sep 17 00:00:00 2001 From: Scott Limmer Date: Sun, 27 Oct 2024 10:04:23 +0000 Subject: [PATCH] Override [smtp] variables with equivalents in connection object specified by email.email_conn_id --- airflow/utils/email.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/airflow/utils/email.py b/airflow/utils/email.py index 3a63b4180472b..6e6f3cb2dc140 100644 --- a/airflow/utils/email.py +++ b/airflow/utils/email.py @@ -249,6 +249,14 @@ def send_mime_email( from airflow.hooks.base import BaseHook airflow_conn = BaseHook.get_connection(conn_id) + + e_from = airflow_conn.extra_dejson['from_email'] + smtp_host = airflow_conn.host + smtp_port = airflow_conn.port + smtp_starttls = not airflow_conn.extra_dejson['disable_tls'] + smtp_ssl = not airflow_conn.extra_dejson['disable_ssl'] + smtp_retry_limit = airflow_conn.extra_dejson['retry_limit'] + smtp_timeout = airflow_conn.extra_dejson['timeout'] smtp_user = airflow_conn.login smtp_password = airflow_conn.password except AirflowException: