EmailOperator for notifications in Apache Airflow - Practice Problems & Coding Challenges

Challenge - 5 Problems

💻 Command Output

intermediate

What is the output of this Airflow EmailOperator task?

Given the following Airflow task using EmailOperator, what will be the result when the task runs successfully?

Apache Airflow

from airflow.operators.email import EmailOperator
email_task = EmailOperator(
    task_id='send_email',
    to='[e-mail]',
    subject='Test Email',
    html_content='<h1>Hello</h1>',
    dag=None
)

result = email_task.execute(context={})

A Returns the string 'Email sent successfully' without sending email

B Raises a TypeError because 'dag' parameter is None

C Sends an email to [e-mail] with subject 'Test Email' and returns None

D Raises an AirflowException due to missing SMTP configuration

💡 Hint

EmailOperator's execute method sends the email and returns None on success.

EmailOperator sends the email when execute() is called and returns None if successful. It does not return a string or raise error if SMTP is configured properly. 'dag=None' is allowed for standalone task testing.

🧠 Conceptual

intermediate

Which parameter in EmailOperator specifies the email recipient?

In Airflow's EmailOperator, which parameter is used to specify the recipient email address?

A to

B recipient

C email_to

D address

💡 Hint

Think about the common English word used for sending emails.

The 'to' parameter is used to specify the recipient email address in EmailOperator.

❓ Troubleshoot

advanced

Why does this EmailOperator task fail with SMTPAuthenticationError?

An Airflow EmailOperator task fails with the error 'SMTPAuthenticationError: (535, b'Authentication failed')'. What is the most likely cause?

Apache Airflow

email_task = EmailOperator(
    task_id='send_email',
    to='[e-mail]',
    subject='Alert',
    html_content='Task failed',
    dag=dag
)

email_task.execute(context={})

A Missing 'to' parameter in EmailOperator

B Incorrect SMTP server credentials configured in Airflow settings

C The 'html_content' parameter is empty

D The DAG is not scheduled properly

💡 Hint

SMTPAuthenticationError means the email server rejected login.

SMTPAuthenticationError indicates the SMTP server credentials are wrong or missing in Airflow's configuration.

🔀 Workflow

advanced

In which Airflow DAG event is EmailOperator best used for failure notifications?

You want to send an email notification only when a DAG task fails. Which Airflow feature allows you to trigger EmailOperator only on failure?

A Adding EmailOperator as the first task in the DAG

B Setting 'trigger_rule' to 'all_success'

C Using 'start_date' to schedule the email

D Using the 'on_failure_callback' parameter in the task

💡 Hint

Callbacks run on specific task events like failure or success.

'on_failure_callback' lets you specify a function or operator to run when a task fails, perfect for sending failure emails.

✅ Best Practice

expert

What is the best practice to avoid exposing email credentials in Airflow EmailOperator?

To keep email server credentials secure when using EmailOperator in Airflow, what is the recommended approach?

A Store credentials in Airflow Connections and reference them in EmailOperator

B Hardcode credentials directly in the DAG file

C Use environment variables inside the DAG code without encryption

D Include credentials in the email content for transparency

💡 Hint

Airflow Connections are designed to securely store credentials.

Airflow Connections securely store credentials and can be referenced by operators, avoiding hardcoding sensitive data.