Master_runner.Make
module D : Communication.Distributed_wrapper.Enriched_process with type 'a io = 'a Lwt.t
type node = {
name : string;
ip : string;
port : int;
}
type 'a master_task := workers:Distributed.Process_id.t list -> 'a D.t
val run : self_node:node -> nodes:node list -> 'a master_task -> 'a