duxingchen/WQ_GUI
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试修改

Browse Source
This commit is contained in:
DXC
2026-06-23 16:12:58 +08:00
parent e907e73810
commit 948d1d8acd
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/gui/core/pipeline_executor.py
View File

@ -308,7 +308,7 @@ class PipelineExecutor(QObject):
global_event_bus.publish('LogMessage', {'message': '开始执行完整流程...', 'level': 'info'}) global_event_bus.publish('LogMessage', {'message': '开始执行完整流程...', 'level': 'info'})
global_event_bus.publish('LogMessage', {'message': '=' * 50, 'level': 'info'}) global_event_bus.publish('LogMessage', {'message': '=' * 50, 'level': 'info'})
# ★ 启动看门狗：worker.start() 之后立刻开始监控（180s 超时） # ★ 启动看门狗：worker.start() 之后立刻开始监控（600s 超时）
import time import time
self._last_progress_time = time.time() self._last_progress_time = time.time()
self._watchdog_timer.start(5000) # 每 5 秒巡检一次 self._watchdog_timer.start(5000) # 每 5 秒巡检一次
@ -385,7 +385,7 @@ class PipelineExecutor(QObject):
}) })
global_event_bus.publish('LogMessage', {'message': '=' * 50, 'level': 'info'}) global_event_bus.publish('LogMessage', {'message': '=' * 50, 'level': 'info'})
# ★ 启动看门狗：worker.start() 之后立刻开始监控（180s 超时） # ★ 启动看门狗：worker.start() 之后立刻开始监控（600s 超时）
import time import time
self._last_progress_time = time.time() self._last_progress_time = time.time()
self._watchdog_timer.start(5000) # 每 5 秒巡检一次 self._watchdog_timer.start(5000) # 每 5 秒巡检一次
@ -515,14 +515,14 @@ class PipelineExecutor(QObject):
判定逻辑： 判定逻辑：
- Worker 已不在运行（自然结束/被强杀） → 停掉看门狗 - Worker 已不在运行（自然结束/被强杀） → 停掉看门狗
- Worker 仍在运行 + 上次进度距今 > 180 秒 → 判定为假死/死锁， - Worker 仍在运行 + 上次进度距今 > 600 秒 → 判定为假死/死锁，
强制 terminate() 并通过 _on_finished(False, ...) 汇流解 UI， 强制 terminate() 并通过 _on_finished(False, ...) 汇流解 UI，
让被卡死的「独立运行此步骤」按钮恢复可用。 让被卡死的「独立运行此步骤」按钮恢复可用。
""" """
import time import time
if self._worker and self._worker.isRunning(): if self._worker and self._worker.isRunning():
if time.time() - self._last_progress_time > 180: if time.time() - self._last_progress_time > 600:
self._log_message("[错误] 后台任务响应超时（超过3分钟无响应），强制终止...", "error") self._log_message("[错误] 后台任务响应超时（超过10分钟无响应），强制终止...", "error")
self._worker.terminate() self._worker.terminate()
self._on_finished(False, "后台任务响应超时或发生底层段错误，已强制终止。") self._on_finished(False, "后台任务响应超时或发生底层段错误，已强制终止。")
else: else: