Vue d'ensemble

Airflow 2.10, publié le 29 octobre 2024, introduit le Task SDK pour simplifier la création de tâches et améliore l'interface utilisateur.

Fonctionnalités principales

Task SDK

Le Task SDK simplifie la création de tâches avec une API plus intuitive et un meilleur typage.

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

@dag(schedule='@daily', start_date=datetime(2024, 1, 1))
def mon_pipeline():
    @task
    def extraire():
        return {'donnees': [1, 2, 3]}

    @task
    def transformer(donnees: dict):
        return [x * 2 for x in donnees['donnees']]

    transformer(extraire())

mon_pipeline()

Sources