def set_exe(self, pipes_code):
if not self.output:<EOL><INDENT>raise RuntimeError("<STR_LIT>")<EOL><DEDENT>parent = hdfs.path.dirname(hdfs.path.abspath(self.output.rstrip("<STR_LIT:/>")))<EOL>self.exe = hdfs.path.join(parent, utils.make_random_str())<EOL>hdfs.dump(pipes_code, self.exe)<EOL>
Dump launcher code to the distributed file system.