EmailOperator in Airflow: What It Is and How to Use It

EmailOperator in Airflow is a built-in task operator that sends emails as part of a workflow. It helps automate email notifications by defining email details like recipients, subject, and message within a DAG.

How It Works

EmailOperator works like a mailman in your Airflow workflow. When the task runs, it sends an email using the details you provide, such as who to send it to, the subject, and the message content. It uses the email settings configured in Airflow to connect to an email server and deliver the message.

Think of it as setting up a reminder or alert that automatically goes out when a certain step in your workflow finishes or fails. This helps keep your team informed without manual effort.

Example

This example shows how to use EmailOperator to send a simple email notification from an Airflow DAG.

python

from airflow import DAG
from airflow.operators.email import EmailOperator
from datetime import datetime

default_args = {
    'start_date': datetime(2024, 1, 1),
}

dag = DAG('email_example', default_args=default_args, schedule_interval='@once')

send_email = EmailOperator(
    task_id='send_email',
    to='[e-mail]',
    subject='Airflow EmailOperator Test',
    html_content='<h3>This is a test email from Airflow</h3>',
    dag=dag
)

Output

When the DAG runs, an email is sent to [e-mail] with the subject and HTML content specified.

When to Use

Use EmailOperator when you want to automate sending emails as part of your workflow. Common uses include:

• Notifying team members when a job completes successfully or fails.
• Sending reports or alerts automatically.
• Triggering manual actions by informing stakeholders.

This operator is helpful in monitoring workflows and keeping communication timely without manual intervention.

Key Points

• EmailOperator sends emails using Airflow's configured SMTP settings.
• You specify recipients, subject, and message content in the operator.
• It is useful for notifications and alerts in workflows.
• Requires proper email server setup in Airflow configuration.

Key Takeaways

EmailOperator automates email sending within Airflow workflows.

It requires SMTP email server settings configured in Airflow.

Use it to notify teams or send alerts based on task outcomes.

You define email details like recipients, subject, and content in the operator.

It helps keep workflow communication automatic and timely.