What is TaskFlow API?

TaskFlow is a more Pythonic way to write DAGs with @task:

@task
def extract():
    return "data.csv"

@task
def process(file):
    print(file)

process(extract())

Airflow wires dependencies and XCom for you. Cleaner, more readable, easier to maintain than always using classic operators + manual XCom.