revoke

app_utils.py

@@ -223,11 +223,10 @@ def stream_simulation_results(result_folder: str, task_id: str, request: gr.Requ
 
     while max_time > 0:
         max_time -= 1
-        # current_time = time.time()
+        current_time = time.time()
         
         # 定期检查后端状态
-        # if current_time - last_status_check > status_check_interval:
-        if True:
+        if current_time - last_status_check > status_check_interval:
             status = get_task_status(task_id)
             print(str(request.session_hash), "status: ", status)
             if status.get("status") == "completed":
@@ -240,7 +239,7 @@ def stream_simulation_results(result_folder: str, task_id: str, request: gr.Requ
                 raise gr.Error(f"任务执行失败: {status.get('result', '未知错误')}")
             elif status.get("status") == "terminated":
                 break
-            # last_status_check = current_time
+            last_status_check = current_time
 
         # 从OSS获取文件列表
         try: