ad_material_video/video_job.py

import time
import schedule

from common import Material
from video_rewriting.video_prep import getVideo



def video_start():
    print("开始执行")
    getVideo.video_task()  # 假设这是一个异步函数
    print("执行完成")

# video_start()

schedule.every().day.at("05:30").do(video_start)

while True:
    schedule.run_pending()
    time.sleep(1)