Vue d'ensemble

Airflow 3.1, publie le 25 septembre 2025, ajoute le support OpenTelemetry et les decorateurs @skip_if / @run_if pour le controle conditionnel des taches.

Fonctionnalites principales

OpenTelemetry et decorateurs conditionnels

OpenTelemetry permet l'export de traces et metriques vers des backends comme Jaeger ou Prometheus. Les decorateurs @skip_if et @run_if simplifient la logique conditionnelle des DAGs.

python 
from airflow.decorators import task, dag
from airflow.decorators import skip_if, run_if
from datetime import datetime

@dag(schedule='@daily', start_date=datetime(2025, 1, 1))
def my_dag():

    @task
    @skip_if(lambda ctx: ctx['ds_nodash'] == '20250101')
    def process_data():
        return 'processed'

    @task
    @run_if(lambda ctx: ctx['dag_run'].conf.get('full'))
    def full_refresh():
        return 'refreshed'

    process_data() >> full_refresh()

my_dag()

Sources