job_dd_sph.py 670 B

1234567891011121314151617181920
  1. import time
  2. from common import Material
  3. from video_rewriting.video_processor import VideoProcessor
  4. def video_task_start():
  5. """处理视频任务,返回用户名并根据结果决定延迟时间"""
  6. data = Material.feishu_list()[12]
  7. while True:
  8. try:
  9. print("开始执行任务")
  10. mark = VideoProcessor.main(data)
  11. print(f"返回用户名: {mark}")
  12. time.sleep(120 if mark else 120) # 根据 mark 是否为空设置延迟
  13. except Exception as e:
  14. print("处理任务时出现异常:", e)
  15. time.sleep(10)
  16. continue
  17. if __name__ == '__main__':
  18. video_task_start()