Update app.py

app.py

@@ -59,8 +59,8 @@ VIDEOS_PER_BATCH = 10
 TASKS_ROOT_DIR = "tasks_data" 
 
 # 🔥🔥 极限并发 🔥🔥
-VIDEO_WORKERS = 5000         
-LLM_WORKERS = 5000           
+VIDEO_WORKERS = 5000          
+LLM_WORKERS = 5000            
 RENDER_PARALLELISM = 4       # 渲染线程保持4以防爆内存
 
 # 全局渲染锁
@@ -849,6 +849,11 @@ def submit_batch_tasks(sys_prompt, *file_lists):
         except Exception as e:
             skipped_info.append(f"窗口 #{task['index']} 启动报错: {str(e)}")
 
+    # 🔥 核心修复：防止 started_ids 为空导致 crash
+    if not started_ids:
+        err_msg = "❌ 所有任务启动失败，请检查以下错误信息:\n" + "\n".join(skipped_info)
+        return err_msg, None
+
     # 构建返回消息
     msg_lines = [f"🚀 成功启动 {len(started_ids)} 个任务！"]
     msg_lines.append(f"ID: {', '.join(started_ids)}")
@@ -860,7 +865,8 @@ def submit_batch_tasks(sys_prompt, *file_lists):
 
 def refresh_task_list():
     tasks = task_manager.list_tasks()
-    return gr.Dropdown(choices=tasks, value=tasks[0] if tasks else None)
+    # 🔥 核心修复：原子更新
+    return gr.update(choices=tasks, value=tasks[0] if tasks else None)
 
 def get_task_details(task_id):
     if not task_id: return "请选择任务", None, None
@@ -870,7 +876,7 @@ def get_task_details(task_id):
 
 def handle_clear_storage():
     success, msg = task_manager.clear_all_tasks()
-    return msg, gr.Dropdown(choices=[], value=None)
+    return msg, gr.update(choices=[], value=None)
 
 # ================= UI 构建 =================
 
@@ -908,7 +914,8 @@ with gr.Blocks(title="Veo V9.3 Grid Batch Edition") as demo:
             with gr.Row():
                 with gr.Column(scale=1):
                     refresh_list_btn = gr.Button("🔄 刷新任务列表")
-                    task_dropdown = gr.Dropdown(label="选择历史任务", choices=[], interactive=True)
+                    # 🔥 核心修复：allow_custom_value 防止验证报错
+                    task_dropdown = gr.Dropdown(label="选择历史任务", choices=[], interactive=True, allow_custom_value=True)
                     status_display = gr.Label("当前状态: 准备就绪")
                     download_file = gr.File(label="下载成品 (ZIP)")
                     
@@ -927,11 +934,15 @@ with gr.Blocks(title="Veo V9.3 Grid Batch Edition") as demo:
         outputs=[submit_result, new_task_id_storage]
     )
 
+    # 🔥 核心修复：原子更新函数
     def auto_select_new_task(new_id):
         all_tasks = task_manager.list_tasks()
-        if new_id and new_id in all_tasks:
-            return gr.Dropdown(choices=all_tasks, value=new_id)
-        return gr.Dropdown(choices=all_tasks, value=all_tasks[0] if all_tasks else None)
+        if new_id:
+            if new_id not in all_tasks:
+                all_tasks.insert(0, new_id)
+            # 使用 gr.update 同时更新列表和值
+            return gr.update(choices=all_tasks, value=new_id)
+        return gr.update(choices=all_tasks, value=all_tasks[0] if all_tasks else None)
     
     submit_btn.click(auto_select_new_task, new_task_id_storage, task_dropdown)
     refresh_list_btn.click(refresh_task_list, outputs=task_dropdown)