Классика: t1 >> t2 >> [t3, t4], t3 << t1, или set_upstream/set_downstream. TaskFlow связывает через вызовы функций/XComArg.
Разбор
- Bitshift-синтаксис читается как поток данных вправо.
- Список справа — параллельные downstream.
- Избегайте случайных циклов при динамической генерации.
- Dummy/EmptyOperator иногда как join-точка.
Пример
extract >> transform >> load
Итог
Зависимости задают порядок и fan-out/fan-in графа tasks.
