BigData / Apache Airflow Interview Questions

What are SLAs in Apache Airflow and how are they configured?

SLAs (Service Level Agreements) in Airflow allow you to define the maximum time by which a task or DAG should complete after the scheduled execution date. If the deadline is missed, Airflow sends an email alert and logs an SLA miss event.

from datetime import timedelta

with DAG(
    'sla_example',
    sla_miss_callback=my_sla_callback,
    default_args={'sla': timedelta(hours=2)},
    ...
) as dag:
    t = PythonOperator(task_id='task', python_callable=my_func)

SLA misses appear in the Airflow UI under Browse > SLA Misses. Note: SLAs are measured from the scheduled execution date, not the actual start time.

Take quiz

From when is an Airflow SLA miss measured? From the scheduled execution date

✓ Correct! Well done.

From the actual task start time

✗ Try again if not.

From when the DAG file was last parsed

✗ Try again if not.

More Related questions...

What is Apache Airflow? What is a DAG in Apache Airflow? What are Operators in Apache Airflow? What is the Airflow Scheduler? What are the main components of Apache Airflow? What is an Executor in Airflow and what types are available? What is an Airflow Connection? What is an Airflow Variable? What is XCom in Airflow and how is it used? What are Hooks in Apache Airflow? What is the difference between a DAG Run and a Task Instance in Airflow? What are Sensors in Apache Airflow? What is catchup in Airflow and how does it work? What is backfilling in Apache Airflow? What is the TaskFlow API in Airflow? What is the difference between schedule_interval and timetable in Airflow? What is a SubDAG and why is it generally discouraged? What is a TaskGroup in Airflow? What is branching in Airflow and how is BranchPythonOperator used? What are trigger rules in Airflow? What is the Airflow metadata database and what does it store? How does the CeleryExecutor work in Airflow? What is the KubernetesExecutor and what are its benefits? What are Pools in Apache Airflow? What are Airflow Providers? What is dynamic task mapping in Airflow? What is the difference between depends_on_past and wait_for_downstream in Airflow? What is the Airflow Web UI and what can you do with it? What are Airflow task states and what do they mean? What are retries and retry_delay in Airflow tasks? What is a Deferrable Operator (async operator) in Airflow? What are Airflow Plugins? How does Airflow handle templating and macros? What is idempotency in the context of Airflow tasks? What are best practices for writing efficient Airflow DAGs? What is the ExternalTaskSensor in Airflow? What is the KubernetesPodOperator in Airflow? What are SLAs in Apache Airflow and how are they configured? How does Airflow handle task concurrency and parallelism? What is an Airflow Dataset and how does data-driven scheduling work? What is the difference between Airflow and Apache Spark? How do you deploy Apache Airflow using Docker Compose? What is Airflow on Kubernetes (KEDA) autoscaling? What is the SparkSubmitOperator in Airflow? What is Managed Airflow (MWAA) on AWS? How does Airflow handle secrets management? What is the difference between PythonOperator and PythonVirtualenvOperator? What is the Grid view in Airflow 2.x? What are common Airflow anti-patterns to avoid? What is Airflow 2 vs Airflow 1 — key differences?

Show more question and Answers...

Apache Parquet Interview Questions

Comments & Discussions

Hadoop basics 33 Hadoop MapReduce 7 Apache Spark 23 TensorFlow 6 Data pipeline interview questions 12 Splunk Interview Questions 23 Tableau Interview Questions 52 Apache Airflow Interview Questions 50 Apache Parquet Interview Questions 30 Data Lake Interview questions 40 Apache Iceberg Interview questions 50

Recently added questions

How do you search for UDM events in Google SecOps? What is Gemini in Google SecOps used for? What is Chronicle SOAR? What is Google Threat Intelligence? How do you ingest logs into Google SecOps? What is data retention in Google SecOps? What is the Unified Data Model (UDM)? What is Chronicle SIEM? What is a playbook in Google SecOps SOAR? What are curated detections? What are the required sections of a YARA-L rule? What is a parser in Google SecOps? What is a forwarder in Google SecOps? What are reference lists used for? What is Google SecOps? What is the purpose of Google SecOps? What is YARA-L? What are the core components of Google SecOps? Define a case in Google SecOps SOAR? List the ways to access Google SecOps search?

	Interviews Questions Java Spring Hibernate DevOps Testing API BigData Web Erlang AI Database Integration Cloud Python Scala Tools Golang SAP	About Javapedia.net Javapedia.net is for Java and J2EE developers, technologist and college students who prepare of interview. Also this site includes many practical examples. This site is developed using J2EE technologies by Steve Antony, a senior Developer/lead at one of the logistics based company. Follow Javapedia updates
	contact: javatutorials2016[at]gmail[dot]com
Kindly consider donating for maintaining this website. Thanks.
	Copyright © 2026, javapedia.net, all rights reserved. Privacy Policy · Terms of Service.