def run(self):
try:<EOL><INDENT>self.listen()<EOL><DEDENT>except Exception as e:<EOL><INDENT>logger.critical("<STR_LIT>", str(e))<EOL>logger.critical(traceback.format_exc())<EOL><DEDENT>
Run thread to listen for jobs and reschedule successful ones.