Airflow DAG and SQL | Dataford Interview Questions

Describe how you would build an Airflow DAG to run SQL transformations, including how you would schedule and validate the results.

Explain the task dependencies, scheduling approach, retry and failure behavior, idempotency strategy, and SQL checks used to verify the transformed data.

Output

Produce one row per order date and customer country for qualifying orders.
Return order_date, country, order_count, and gross_revenue.
Include delivered and shipped orders, map missing countries to Unknown, and order by date and country.

Schema

raw_orders

Column	Type	Description
order_idPK	INT	Unique order identifier
order_date	DATE	Date on which the order was placed
customer_id	INT	Customer associated with the order
status	VARCHAR(20)	Current order status
amount	DECIMAL(10,2)	Order monetary amount

customers

Column	Type	Description
customer_idPK	INT	Unique customer identifier
country	VARCHAR(50)	Customer country

Your question is Airflow DAG and SQL. Start with the requirements and the two tables in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.

Problem