增加超时时间

wx_message_job.py

@@ -20,7 +20,8 @@ def video_task():
     # 创建一个线程池
     with concurrent.futures.ThreadPoolExecutor() as executor:
         futures = {executor.submit(video_start, user_data): user_data for user_data in data}
-        for future in concurrent.futures.as_completed(futures):
+        timeout = 10 * 60
+        for future in concurrent.futures.as_completed(futures, timeout=timeout):
             try:
                 # 获取每个任务的执行结果
                 result = future.result()