Somehow I would expect pipes to be connectable and nestable.
This does not seem to be the case (by studying the source).
Then you could have some function to build and parametrise a sub-pipeline and connect them to something bigger.
I'm still looking for a perfect natural python ETL dsl, so I will follow that project.
So far I'm using https://github.com/petl-developers/petl and mostly happy with it.