sig
  val pipe :
    [< Log.Output.machine_readable_format ] ->
    string -> Log.Message.t Import.Pipe.Reader.t
end