airflow_dag_smtp_operator_email_sending_quickstart.py

1import datetime
2
3from airflow import DAG
4from airflow.providers.smtp.operators.smtp import SmtpOperator
5
6with DAG(
7    dag_id="example_smtp_operator",
8    start_date=datetime.datetime(2021, 1, 1),
9    schedule=None,
10    catchup=False,
11) as dag:
12    # [START howto_operator_smtp]
13    send_email = SmtpOperator(
14        task_id="send_email",
15        to="to@example.com",
16        subject="Airflow SMTP Operators",
17        html_content=""" <h3>SMTP Operator Test</h3>
18            Everything is working fine! <br>
19            """,
20    )
21    # [END howto_operator_smtp]