aggregate pipeline