def run(self, **kwargs):
if not (self.input and self.output and self.exe):<EOL><INDENT>raise RuntimeError("<STR_LIT>")<EOL><DEDENT>self.logger.info("<STR_LIT>")<EOL>run_pipes(self.exe, self.input, self.output, **kwargs)<EOL>
Run the pipes job.  Keyword arguments are passed to :func:`run_pipes`.