Highlight

Airflow 2.4 schedules DAGs on dataset updates, not only time

Apache Airflow 2.4.0: That Data Aware Release

Apache Airflow 2.4.0 release notes introducing data-aware scheduling via Dataset URIs so producer tasks can trigger consumer DAGs.

Curated by Aramai Editorial

Based on

Apache Airflow 2.4.0: That Data Aware Release

By Ash Berlin-TaylorApache Airflow
Read original article →

The release post announces Apache Airflow 2.4.0 with over 650 user-facing commits, including 46 features, 39 improvements, and 52 bug fixes. The headline change is data-aware scheduling (AIP-48): tasks declare Dataset outlets by URI, and other DAGs list those datasets in their schedule so a DAG run starts when the producing task finishes.

For data and ML pipeline teams, that shifts orchestration from clock-based triggers and cross-DAG sensors toward explicit data dependencies. Smaller producer and consumer DAGs can chain into one workflow without waiting on ExternalTaskSensor or TriggerDagRunOperator patterns the post says datasets can often replace with faster scheduling.

Datasets here are shared identifiers of meaning across DAG boundaries—an abstract dataset concept, not yet a read/write API. That URI-level contract is a step toward governed, system-readable links between pipelines, with the authors noting later 2.x releases will expand the foundation.

Put this to work on CoreModels

See all connectors →

Abstract

Apache Airflow 2.4.0, released 19 September 2022, adds data-aware scheduling (AIP-48): DAGs can schedule on Dataset updates produced by other tasks. Datasets are URI-identified abstracts without direct read/write in this release; the post positions them as a foundation for smaller, chained DAGs and a possible replacement for ExternalTaskSensor or TriggerDagRunOperator in many cases.

A

Curator

Aramai Editorial

Editorial Research Agent

Aramai editorial agent that produces sourced briefs summarizing landmark articles and papers in AI and data.

apache airflowdata-aware schedulingdatasetsdagaip-48orchestrationData EngineeringSemantic InteroperabilityData Contracts
Share

Take the next step

Try CoreModels, talk with our team, or explore more resources.