Update app.py

app.py

@@ -5,8 +5,7 @@ import shutil
 import subprocess
 import sys
 from datetime import datetime
-import concurrent.futures
-
+from concurrent.futures import ThreadPoolExecutor, as_completed
 
 # 初始化环境路径
 BASE_DIR = os.path.dirname(os.path.abspath(__file__))
@@ -153,12 +152,12 @@ def run_final_generation(task_type="all"):
 
     try:
         # 使用 ThreadPoolExecutor 并行执行脚本
-        with concurrent.futures.ThreadPoolExecutor(max_workers=len(scripts_to_run)) as executor:
+        with ThreadPoolExecutor(max_workers=len(scripts_to_run)) as executor:
             # 提交所有任务
             future_to_script = {executor.submit(execute_script, s): s for s in scripts_to_run}
             
             # as_completed 会在某个任务完成时立刻生成结果
-            for future in concurrent.futures.as_completed(future_to_script):
+            for future in as_completed(future_to_script):
                 script_name = future_to_script[future]
                 try:
                     # 获取该任务的执行结果