Overview

Airflow 2.10, released on October 29, 2024, introduces the Task SDK for simpler task creation and improves the user interface.

Main Features

Task SDK

The Task SDK simplifies task creation with a more intuitive API and better typing.

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

@dag(schedule='@daily', start_date=datetime(2024, 1, 1))
def my_pipeline():
    @task
    def extract():
        return {'data': [1, 2, 3]}

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

    transform(extract())

my_pipeline()

Sources