RUBY-596 Aggregation pipeline (WIP)