worker.py 文件源码

def start_worker(self, schedule_id, worker_schedule):
        self.schedule_id = schedule_id
        schedule.clear()
        self._setup_worker_schedule(worker_schedule)
        global scheduler_running
        global scheduler_done
        scheduler_done = False
        if not scheduler_running:
            scheduler_running = True
            self.schedule_thread = Thread(target=run_scheduler)
            self.schedule_thread.start()
        self.resume_worker()
        self._send_event_to_master('on_start')