job_submitter.py 文件源码

def run(self):
        while not self.event.is_set():
            try:
                self.process_pending_jobs()
            except peewee.OperationalError:
                log.warning('Lost database connection')
            except:
                log.exception('Error during submission')
            self.event.wait(self.interval)