import time
import schedule
from tasks.experiment.expirment_tasks import deal


def do_job():
    """<UNK>"""
    print("开始执行任务...")
    deal()
    print("任务执行完成！")

def run_scheduler():
    """调度器运行函数"""
    # 每天5:00执行
    schedule.every().day.at("15:41").do(do_job)

    print("调度器已启动，等待执行时间...")
    while True:
        schedule.run_pending()
        time.sleep(60)  # 每分钟检查一次


if __name__ == "__main__":
    run_scheduler()