pub fn compute_pi<'a>( flow: &FlowBuilder<'a>, batch_size: usize, ) -> (Cluster<'a, Worker>, Process<'a, Leader>)