EmailOperator for notifications in Apache Airflow - Cheat Sheet & Quick Revision

Recall & Review

beginner

What is the purpose of the EmailOperator in Airflow?

The EmailOperator is used to send email notifications from Airflow workflows, such as alerts or status updates.

beginner

Which parameter specifies the recipient email address in EmailOperator?

The to parameter specifies the recipient email address or list of addresses.

beginner

How do you define the subject line of the email in EmailOperator?

Use the subject parameter to set the email's subject line.

intermediate

What must be configured in Airflow to enable EmailOperator to send emails?

You must configure the SMTP server settings in Airflow's airflow.cfg or environment variables to enable sending emails.

beginner

Show a simple example of EmailOperator usage in a DAG.

Example:

email_task = EmailOperator(
    task_id='send_email',
    to='[e-mail]',
    subject='Airflow Notification',
    html_content='Your task completed successfully.',
    dag=dag
)

Which parameter in EmailOperator sets the email content?

A html_content

B to

C subject

D smtp_host

The html_content parameter defines the body of the email message.

What must be configured for EmailOperator to send emails successfully?

A SMTP server settings

B Database connection

C Kubernetes cluster

D Docker image

SMTP server settings allow Airflow to connect and send emails.

Can EmailOperator send emails to multiple recipients?

A No, only one email address is allowed

B Yes, by passing a list to the 'to' parameter

C Yes, but only one at a time manually

D No, it sends to the default admin only

You can pass a list of email addresses to the to parameter.

Which Airflow component runs the EmailOperator task?

A Scheduler

B Metadata Database

C Executor

D Webserver

The Executor runs tasks including EmailOperator.

What is the minimum required parameter to create an EmailOperator?

A to

B subject

C html_content

D task_id

Every operator requires a task_id to identify the task.

Explain how to set up and use EmailOperator in an Airflow DAG to send a notification email.

Think about the parameters needed and Airflow configuration.

What are the key configuration steps to enable Airflow to send emails using EmailOperator?

Focus on SMTP and Airflow settings.

Practice

1. What is the primary purpose of the EmailOperator in Airflow?

easy

A. To store logs of task executions

B. To schedule tasks at specific times

C. To monitor CPU usage of Airflow workers

D. To send emails automatically from Airflow tasks

Solution

1. Step 1: Understand EmailOperator's role

   EmailOperator is designed to send emails triggered by Airflow tasks.

2. Step 2: Compare with other options

   Scheduling tasks, storing logs, and monitoring CPU are handled by other Airflow components, not EmailOperator.

3. Final Answer:

   To send emails automatically from Airflow tasks -> Option D

4. Quick Check:

   EmailOperator = send emails [OK]

Hint: EmailOperator is for sending emails, not scheduling [OK]

Common Mistakes:

• Confusing EmailOperator with scheduling operators
• Thinking EmailOperator manages logs or monitoring
• Assuming EmailOperator runs tasks instead of notifying

2. Which of the following is the correct way to import EmailOperator in an Airflow DAG file?

easy

A. from airflow.operators.email_operator import Email

B. from airflow.operators.email import EmailOperator

C. from airflow.operators.email_operator import EmailOperator

D. import EmailOperator from airflow.operators.email_operator

Solution

1. Step 1: Recall correct import path

   The correct import path for EmailOperator in Airflow is from airflow.operators.email_operator import EmailOperator.

2. Step 2: Check other options for syntax or naming errors

   from airflow.operators.email import EmailOperator uses wrong module name (missing '_operator'); from airflow.operators.email_operator import Email imports wrong class name; import EmailOperator from airflow.operators.email_operator uses invalid Python import syntax.

3. Final Answer:

   from airflow.operators.email_operator import EmailOperator -> Option C

4. Quick Check:

   Correct import = airflow.operators.email_operator [OK]

Hint: Use 'from airflow.operators.email_operator import EmailOperator' [OK]

Common Mistakes:

• Using wrong module path like email
• Incorrect import syntax like 'import X from Y'
• Confusing class name with module name

3. Given this Airflow task using EmailOperator:

email_task = EmailOperator(
    task_id='send_email',
    to='[e-mail]',
    subject='Test Email',
    html_content='Hello from Airflow!',
    dag=dag
)

What will happen when this task runs successfully?

medium

A. The task will send an email but with empty content

B. An email with subject 'Test Email' is sent to [e-mail]

C. No email is sent because 'to' is not a list

D. The task will fail because html_content is missing

Solution

1. Step 1: Analyze EmailOperator parameters

   The task specifies 'to' as a string email address, 'subject', and 'html_content' correctly.

2. Step 2: Understand EmailOperator behavior

   EmailOperator accepts a string or list for 'to' and sends the email with given subject and content.

3. Final Answer:

   An email with subject 'Test Email' is sent to [e-mail] -> Option B

4. Quick Check:

   Valid params = email sent [OK]

Hint: Single string 'to' is valid for EmailOperator [OK]

Common Mistakes:

• Thinking 'to' must be a list
• Assuming html_content is required to be a file
• Believing task fails without attachments

4. You wrote this EmailOperator task but it fails with an error:

email_task = EmailOperator(
    task_id='notify',
    to=['[e-mail]'],
    subject='Alert',
    html_content='Check this alert',
    dag=dag
)

What is the most likely cause of the failure?

medium

A. SMTP server is not configured in Airflow settings

B. The 'to' parameter must be a string, not a list

C. Missing 'from_email' parameter in EmailOperator

D. The 'subject' parameter cannot contain spaces

Solution

1. Step 1: Check EmailOperator parameters

   The 'to' parameter accepts a list, and 'subject' with spaces is valid.

2. Step 2: Identify common failure cause

   EmailOperator requires SMTP server setup in Airflow config; missing this causes failure.

3. Final Answer:

   SMTP server is not configured in Airflow settings -> Option A

4. Quick Check:

   SMTP setup missing = failure [OK]

Hint: Check SMTP config if EmailOperator fails [OK]

Common Mistakes:

• Assuming 'to' cannot be a list
• Thinking the 'subject' parameter cannot contain spaces
• Thinking 'from_email' is mandatory parameter

5. You want to send an email notification only when a task fails using EmailOperator. Which Airflow feature should you use to trigger the email task only on failure?

hard

A. Set trigger_rule="one_failed" on the EmailOperator task

B. Set trigger_rule="all_success" on the EmailOperator task

C. Use depends_on_past=True on the EmailOperator task

D. Set email_on_failure=False in the DAG definition

Solution

1. Step 1: Understand trigger_rule usage

   Setting trigger_rule="one_failed" makes the task run only if any upstream task fails.

2. Step 2: Evaluate other options

   all_success runs only if all succeed; depends_on_past controls task dependency on previous runs; email_on_failure is a DAG-level flag, not for task trigger.

3. Final Answer:

   Set trigger_rule="one_failed" on the EmailOperator task -> Option A

4. Quick Check:

   Trigger on failure = trigger_rule one_failed [OK]

Hint: Use trigger_rule='one_failed' to run on failure only [OK]

Common Mistakes:

• Using trigger_rule='all_success' for failure notification
• Confusing depends_on_past with failure triggers
• Misusing email_on_failure flag for task triggers