Skip to content

[WIP] Override smtp config variables with connection values specified by email_conn_id #43413

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
scottlimmer wants to merge 3 commits into from
Closed

[WIP] Override smtp config variables with connection values specified by email_conn_id #43413

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ad3fa49
Override [smtp] variables with equivalents in connection object speci…
scottlimmer Oct 27, 2024
ec534b2
Merge branch 'main' into 34554
scottlimmer Oct 27, 2024
9fd8d15
Merge branch 'main' into 34554
scottlimmer Oct 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions airflow/utils/email.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down