L'API TaskFlow permet de définir un DAG avec des fonctions Python décorées par @dag et @task. Les valeurs retournées par une tâche et passées en argument à la suivante sont transmises automatiquement via XCom, et les dépendances se déduisent des appels de fonctions, ce qui allège l'écriture.
Exemple
@task
def extraire(): return [1, 2, 3]
@task
def charger(lignes): print(lignes)
charger(extraire())