Add as.pipeline.pipe
Remove ... from flow generic