Why orchestration is needed for data pipelines in Apache Airflow - Test Your Understanding

Practice - 5 Tasks

1fill in blank

easy

Complete the code to define a simple Airflow DAG with a start date.

Apache Airflow

from airflow import DAG
from datetime import datetime

dag = DAG('example_dag', start_date=[1])

Drag options to blanks, or click blank then click option'

Adatetime(2023, 1, 1)

Bdatetime.now()

Cdate.today()

Ddatetime.today()

Attempts:

3 left

💡 Hint

Common Mistakes

Using dynamic dates like datetime.now() causes scheduling issues.

The start_date in Airflow DAGs must be a fixed datetime object, not a dynamic call like datetime.now().

2fill in blank

medium

Complete the code to import the operator needed to run a Bash command in Airflow.

Apache Airflow

from airflow.operators.[1] import BashOperator

Drag options to blanks, or click blank then click option'

Abash

Bpython

Cshell

Dcommand

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'python' or 'shell' instead of 'bash' causes import errors.

The BashOperator is imported from airflow.operators.bash to run bash commands.

3fill in blank

hard

Fix the error in the DAG definition by completing the missing argument for the BashOperator.

Apache Airflow

task1 = BashOperator(task_id='print_date', bash_command=[1], dag=dag)

Drag options to blanks, or click blank then click option'

Aprint('date')

B'date'

Cdate

D'print date'

Attempts:

3 left

💡 Hint

Common Mistakes

Passing unquoted commands or Python print statements causes runtime errors.

The bash_command argument must be a string with the command to run, like 'date'.

4fill in blank

hard

Fill both blanks to set task dependencies so task1 runs before task2.

Apache Airflow

task1 [1] task2

task1.[2]

Drag options to blanks, or click blank then click option'

A>>

Bset_downstream(task2)

C<<

Dset_upstream(task1)

Attempts:

3 left

💡 Hint

Common Mistakes

Using '<<' or 'set_upstream()' reverses the order of execution.

Using task1 >> task2 or task1.set_downstream(task2) sets task1 to run before task2.

5fill in blank

hard

Fill all three blanks to create a dictionary comprehension that filters tasks with priority > 5.

Apache Airflow

high_priority_tasks = {task_id: priority for task_id, priority in tasks.items() if priority [1] [2]

print(high_priority_tasks.get([3], 'Not found'))

Drag options to blanks, or click blank then click option'

A>

B5

C'task_1'

D==

Attempts:

3 left

💡 Hint

Common Mistakes

Using '==' instead of '>' changes the filter logic.

Using a wrong task ID causes 'Not found' output.

The comprehension filters tasks with priority greater than 5, then prints the priority of 'task_1' or 'Not found' if missing.