experiment_app.py 517 B

123456789101112131415161718192021222324
  1. import time
  2. import schedule
  3. from tasks.experiment.expirment_tasks import deal
  4. def do_job():
  5. """<UNK>"""
  6. print("开始执行任务...")
  7. deal()
  8. print("任务执行完成!")
  9. def run_scheduler():
  10. """调度器运行函数"""
  11. # 每天5:00执行
  12. schedule.every().day.at("06:00").do(do_job)
  13. print("调度器已启动,等待执行时间...")
  14. while True:
  15. schedule.run_pending()
  16. time.sleep(60) # 每分钟检查一次
  17. if __name__ == "__main__":
  18. run_scheduler()