code: def run(self, **kwargs):
          
          if not (self.input and self.output and self.exe):
              raise RuntimeError("setup incomplete, can't run")
          self.logger.info("running MapReduce application")
          run_pipes(self.exe, self.input, self.output, **kwargs)
docs: Run the pipes job.  Keyword arguments are passed to :func:`run_pipes`.