pipe(func, *args) передаёт текущий объект первым аргументом в функцию — позволяет встраивать пользовательские шаги в chaining без ломания потока.
Разбор
- Сигнатура
def step(df, **kw) -> DataFrame.
- Улучшает тестируемость шагов пайплайна.
- Не прячьте side-effects записи файлов без явного имени.
- Альтернатива — обычные промежуточные переменные.
Итог
pipe — функциональные шаги внутри fluent-пайплайна Pandas.