sig
  module Make :
    functor (Job : MapReduce.Job) ->
      sig
        val run :
          Async.Std.Reader.t ->
          Async.Std.Writer.t -> unit Async.Std.Deferred.t
      end
  val init : int -> unit Async.Std.Deferred.t
end