def run_job(self, job_name):
        self.logger.debug('entering worker run phase, job id: %s' % job_name)
        if job_name not in self.running_jobs:
            self.logger.debug(
                'job not prepared, refused to run, job id: %s' % job_name)
            return False
        
        job_info = self.running_jobs[job_name]
        
        clock = Clock()
        job_info.clock = clock
        job_info.thread.start()
        
        self.logger.debug('worker starts to run job, id: %s' % job_name)
        return True
dataset/ETHPy150Open chineking/cola/cola/cluster/worker.py/Worker.run_job/original