def prepare(self, job_name, unzip=True, overwrite=False, 
                settings=None):
        self.logger.debug('entering worker prepare phase, job id: %s' % job_name)
        if unzip:
            self._unzip(job_name)
        
        src_job_name = job_name
        job_path = os.path.join(self.job_dir, job_name)
        
        if not os.path.exists(job_path):
            return False
        
        job_desc = import_job_desc(job_path)
        if settings is not None:
            job_desc.update_settings(settings)
        
        job_id = self.ctx.ips.index(self.ctx.ip)
        clear = job_desc.settings.job.clear \
                    if self.ctx.is_local_mode else False
        job_name, working_dir = self.ctx._get_name_and_dir(
            self.working_dir, job_name, overwrite=overwrite, clear=clear)
        
        job = Job(self.ctx, job_path, job_name, job_desc=job_desc,
                  working_dir=working_dir, rpc_server=self.rpc_server,
                  manager=self.ctx.manager, job_offset=job_id)
        t = threading.Thread(target=job.run, args=(True, ))
        
        job_info = WorkerJobInfo(job_name, working_dir)
        job_info.job = job
        job_info.thread = t
        self.running_jobs[src_job_name] = job_info
        
        self.logger.debug(job_name % 'worker prepare phase finished, job id: %s')
        return True
dataset/ETHPy150Open chineking/cola/cola/cluster/worker.py/Worker.prepare/swapped operands of `%`