worker.py 文件源码

def run_scheduler():
    global scheduler_running
    global scheduler_paused
    global scheduler_done
    while scheduler_running:
        if not scheduler_paused:
            schedule.run_pending()
        sleep(1)