Updated reduction with parallel execution and save to elasticsearch