|
|
@@ -317,11 +317,13 @@ class ProgressManager:
|
|
|
)
|
|
|
|
|
|
logger.info(f"取消注册任务: {callback_task_id}")
|
|
|
+ # 强制关闭SSE连接
|
|
|
+ sse_callback_manager.force_close_sse(callback_task_id)
|
|
|
+
|
|
|
# 取消SSE回调注册,避免重复推送
|
|
|
sse_callback_manager.unregister_callback(callback_task_id)
|
|
|
|
|
|
- # 强制关闭SSE连接
|
|
|
- sse_callback_manager.force_close_sse(callback_task_id)
|
|
|
+
|
|
|
|
|
|
logger.info(f"任务关闭: {callback_task_id}")
|
|
|
except Exception as e:
|