Apache Airflow Certification Practice Test 02
Core Workflow Concepts and Integration Scenarios
Apache Airflow Certification Practice Test 02
Core Workflow Concepts and Integration Scenarios
Insightful Saga — Modern Data Engineering Certification Preparation
Question 21
A newly joined Data Engineer at a retail company discovers that daily sales files arrive at unpredictable times. The ETL workflow should not begin until the file is available in cloud storage. The engineering team does not want to continuously run failed tasks while waiting for the file. What Airflow capability should be implemented?
Sensors continuously check for a condition, such as file availability, before allowing downstream tasks to execute.
Question 22
A banking company stores Snowflake credentials centrally. Multiple DAGs need to connect to the same Snowflake environment. What is the BEST Airflow approach?
Question 23
A healthcare company has an extraction task that generates a report filename dynamically. A downstream loading task must use the generated filename. Which Airflow mechanism should be used?
XCom allows tasks to exchange small pieces of information.
Question 24
A logistics company wants a DAG to run every day at 2:00 AM. What Airflow feature controls when the DAG starts?
Question 25
A telecom company uses Airflow to connect with: - Snowflake - Kafka - AWS S3 - PostgreSQL What Airflow component provides reusable integration logic?
Hooks provide reusable interfaces for external systems.
Question 26
A newly hired Data Engineer notices hardcoded bucket names in several DAGs. The company frequently changes environments between: - Dev - QA - Production What should be used instead?
Question 27
A retail company receives data from multiple vendors. A workflow should retry automatically if a temporary network issue occurs during ingestion. Which Airflow capability should be configured?
Question 28
A company accidentally shut down a source system for two days. After recovery, management wants Airflow to process all missed schedule runs. Which concept should be evaluated?
Question 29
A newly joined Engineer notices dozens of tasks simultaneously connecting to a legacy source database. The database becomes overloaded during DAG execution. What Airflow feature can limit concurrent task execution?
Pools restrict the number of tasks using a shared resource.
Question 30
A manufacturing company wants environment-specific configurations stored centrally. Examples include: - Email Recipients - Storage Paths - API Endpoints Which Airflow feature best fits?
Question 31
An airline company wants an Airflow DAG to trigger another DAG after successful completion. Which Airflow capability should be considered?
Question 32
A support engineer notices that a DAG keeps running old historical execution dates unexpectedly. Management only wants future schedules to execute. Which Airflow configuration should be reviewed?
Catchup controls whether missed historical schedules are generated.
Question 33
A healthcare company requires automatic email notifications whenever a critical DAG fails. Which Airflow capability should be configured?
Question 34
A financial institution wants to ensure downstream tasks run only when upstream tasks succeed. Which Airflow concept handles this behavior?
Question 35
A retail company has a task that extracts data from Snowflake. The same extraction logic is reused across multiple DAGs. Which Airflow design principle should be followed?
Question 36
A newly hired engineer wants to see task execution history for troubleshooting. Where should they start?
Question 37
A telecom company has a workflow that waits for a Kafka topic to receive data before processing begins. What Airflow construct is most appropriate?
Question 38
A company wants a downstream task to execute even if one upstream task fails but another succeeds. Which Airflow configuration should be reviewed?
Question 39
A support engineer notices a DAG run failed due to a temporary API outage. The API became available again five minutes later. Which feature could have prevented manual intervention?
Question 40
A newly joined Airflow Engineer reviews a production workflow: 1. Wait for Source File 2. Extract Data 3. Transform Data 4. Load Data 5. Send Notification What is the MOST important Airflow principle demonstrated here?
Airflow's primary purpose is coordinating dependent tasks into reliable end-to-end workflows.