TaskFlow — декораторы @task, которые превращают Python-функции в tasks и автоматически прокидывают XComArg между вызовами, уменьшая boilerplate PythonOperator.
Разбор
- Возврат функции → XCom.
- Можно смешивать с классическими операторами.
- Не тащите гигантские dataframe в return.
@task.virtualenv / docker / kubernetes варианты для изоляции.
Итог
TaskFlow упрощает Python-пайплайны и XCom-связки, сохраняя модель DAG.
