78 real Airflow 3 questions from the Data Engineering bank, as asked in Indian campus drives and tech interviews. Every question has a verified answer and an AI-tutor explanation on placd — free to start.
1. What is Airflow 3.0?
Junior
A.An Airflow construct that caps the number of concurrently running task slots for a labeled resource, throttling load on shared systems.
B.A task attribute that breaks ties when multiple tasks compete for pool slots, with higher-weight tasks scheduled first.
C.The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
D.Airflow 3 scheduling where DAGs are triggered by updates to declared data assets rather than by time, enabling data-aware pipelines.
2. Which term means: "The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs."?
A.Airflow 3.0 — An Airflow construct that caps the number of concurrently running task slots for a labeled resource, throttling load on shared systems.
B.Airflow 3.0 — A pluggable storage layer for cross-task communication (XComs); a custom backend can push large payloads to object storage instead of the metadata DB.
C.Airflow 3.0 — An operator that releases its worker slot while waiting, handing the wait to the triggerer process to free resources during long polls.
D.Airflow 3.0 — The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
A.The async Airflow component that runs trigger coroutines for deferrable operators, efficiently managing many concurrent waits on one process.
B.An executor that distributes tasks to a pool of persistent Celery worker processes via a message broker like Redis or RabbitMQ.
C.An Airflow 3 client library that decouples task authoring and execution from the scheduler, reducing boilerplate and enabling tasks to run remotely or in other languages.
D.The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access.
5. Which term means: "An Airflow 3 client library that decouples task authoring and execution from the scheduler, reducing boilerplate and enabling tasks to run remotely or in other languages."?
A.Task SDK — Airflow 3 ability to watch external systems (like a queue or object store) and trigger DAGs in response to external events.
B.Task SDK — An Airflow 3 packaging concept that groups DAG files and their version so the scheduler can serve a consistent versioned DAG definition.
C.Task SDK — Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
D.Task SDK — An Airflow 3 client library that decouples task authoring and execution from the scheduler, reducing boilerplate and enabling tasks to run remotely or in other languages.
A.The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access.
B.Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
C.An Airflow 3 client library that decouples task authoring and execution from the scheduler, reducing boilerplate and enabling tasks to run remotely or in other languages.
D.An operator that releases its worker slot while waiting, handing the wait to the triggerer process to free resources during long polls.
8. Which term means: "The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access."?
A.Task Execution API — An executor that distributes tasks to a pool of persistent Celery worker processes via a message broker like Redis or RabbitMQ.
B.Task Execution API — Airflow 3 separates task execution from the scheduler via the Task Execution API, enabling edge and remote execution outside the cluster.
C.Task Execution API — Airflow 3 ability to watch external systems (like a queue or object store) and trigger DAGs in response to external events.
D.Task Execution API — The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access.
A.Airflow's decorator-based authoring style where Python functions become tasks and return values flow as dependencies, reducing operator boilerplate.
B.Airflow 3 capability that tracks structural changes to a DAG over time so the UI and API can show which version produced a given run.
C.The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
D.An Airflow 3 mechanism that listens for external signals (such as an AWS SQS message) and triggers a DAG when the watched event arrives.
11. Which term means: "Airflow 3 capability that tracks structural changes to a DAG over time so the UI and API can show which version produced a given run."?
A.DAG versioning — An Airflow feature that expands a single task definition into many parallel task instances at runtime based on the size of an upstream output.
B.DAG versioning — Airflow 3 capability that tracks structural changes to a DAG over time so the UI and API can show which version produced a given run.
C.DAG versioning — The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
D.DAG versioning — Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks.
A.Airflow 3 scheduling where DAGs are triggered by updates to declared data assets rather than by time, enabling data-aware pipelines.
B.An executor that launches each Airflow task as its own Kubernetes pod, giving per-task isolation and resource limits.
C.The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
D.Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks.
14. Which term means: "Airflow 3 scheduling where DAGs are triggered by updates to declared data assets rather than by time, enabling data-aware pipelines."?
A.asset-driven scheduling — Airflow 3 scheduling where DAGs are triggered by updates to declared data assets rather than by time, enabling data-aware pipelines.
B.asset-driven scheduling — An Airflow feature that expands a single task definition into many parallel task instances at runtime based on the size of an upstream output.
C.asset-driven scheduling — The pluggable storage Airflow uses for cross-task message passing; large payloads should use a custom backend (e.g. object storage) not the metadata DB.
D.asset-driven scheduling — The major 2025 release introducing DAG versioning, a Task SDK, the Task Execution API, asset-driven and event-driven scheduling, and removal of SubDAGs and SLAs.
A.Airflow 3 ability to watch external systems (like a queue or object store) and trigger DAGs in response to external events.
B.An Airflow 3 client library that decouples task authoring and execution from the scheduler, reducing boilerplate and enabling tasks to run remotely or in other languages.
C.Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks.
D.Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
A.event-driven scheduling — Airflow 3 separates task execution from the scheduler via the Task Execution API, enabling edge and remote execution outside the cluster.
B.event-driven scheduling — An Airflow 3 mechanism to emit asset updates dynamically at runtime when the exact asset is not known until execution.
C.event-driven scheduling — Airflow 3 ability to watch external systems (like a queue or object store) and trigger DAGs in response to external events.
D.event-driven scheduling — The async Airflow process that runs triggers on an asyncio event loop, letting one process watch hundreds of deferred tasks at once.
20. Which term means: "An operator that releases its worker slot while waiting, handing the wait to the triggerer process to free resources during long polls."?
A.deferrable operator — Airflow's decorator-based authoring style where Python functions become tasks and return values flow as dependencies, reducing operator boilerplate.
B.deferrable operator — An operator that releases its worker slot while waiting, handing the wait to the triggerer process to free resources during long polls.
C.deferrable operator — Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
D.deferrable operator — An executor that distributes tasks to a pool of persistent Celery worker processes via a message broker like Redis or RabbitMQ.
A.The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access.
B.An executor that launches each Airflow task as its own Kubernetes pod, giving per-task isolation and resource limits.
C.The async Airflow component that runs trigger coroutines for deferrable operators, efficiently managing many concurrent waits on one process.
D.An Airflow 3 mechanism that listens for external signals (such as an AWS SQS message) and triggers a DAG when the watched event arrives.
23. Which term means: "The async Airflow component that runs trigger coroutines for deferrable operators, efficiently managing many concurrent waits on one process."?
A.triggerer — An executor that launches each Airflow task as its own Kubernetes pod, giving per-task isolation and resource limits.
B.triggerer — Airflow 3's first-class object (formerly Dataset) representing a unit of data; producing tasks update assets and consuming DAGs schedule on their updates.
C.triggerer — An Airflow 3 packaging concept that groups DAG files and their version so the scheduler can serve a consistent versioned DAG definition.
D.triggerer — The async Airflow component that runs trigger coroutines for deferrable operators, efficiently managing many concurrent waits on one process.
A.An operator that releases its worker slot while idly waiting and hands off the wait to the triggerer, freeing resources during long polls.
B.The Airflow 3 service interface through which workers communicate with the metadata layer, enabling remote and language-agnostic task execution without direct database access.
C.Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
D.Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks.
26. Which term means: "Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI."?
A.scheduler-managed backfill — An Airflow construct that caps the number of concurrently running task slots for a labeled resource, throttling load on shared systems.
B.scheduler-managed backfill — An operator that releases its worker slot while waiting, handing the wait to the triggerer process to free resources during long polls.
C.scheduler-managed backfill — The async Airflow component that runs trigger coroutines for deferrable operators, efficiently managing many concurrent waits on one process.
D.scheduler-managed backfill — Airflow 3 backfills are created and tracked by the scheduler itself rather than a separate CLI process, making them observable in the UI.
29. Which term means: "Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks."?
A.SubDAG removal — An Airflow 3 mechanism to emit asset updates dynamically at runtime when the exact asset is not known until execution.
B.SubDAG removal — The async Airflow process that runs triggers on an asyncio event loop, letting one process watch hundreds of deferred tasks at once.
C.SubDAG removal — Airflow 3 capability that tracks structural changes to a DAG over time so the UI and API can show which version produced a given run.
D.SubDAG removal — Airflow 3 removed SubDAGs (and SLAs) in favor of TaskGroups and asset-based patterns, eliminating a long-standing source of deadlocks.
Showing 30 of 78 Airflow 3 questions — the full set, with answers, explanations and an AI tutor on every question, is inside.
Free to start
Answers, AI explanations, and a scored voice mock interview
Sign up free to check your answers with explanations, ask the AI tutor anything on any question, and take one full AI mock interview — scored like a real panel.