offerpai/offerpie_job_cleaner
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

固定间隔时间

Browse Source
This commit is contained in:
zk
2026-07-09 10:58:53 +08:00
parent 1a270d2c67
commit f50a28bb35
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/services/ai_tool.py
+3 -5
View File
@@ -82,11 +82,10 @@ async def ai_chat(llm: BaseChatModel, system_prompt: str, user_message: str, sce
async def _probe_until_recover(llm: BaseChatModel, system_prompt: str, user_message: str) -> str: async def _probe_until_recover(llm: BaseChatModel, system_prompt: str, user_message: str) -> str:
"""探针：退避重试直到接口恢复，返回成功的响应内容，并打开门闸唤醒所有等待协程""" """探针：固定间隔重试直到接口恢复，返回成功的响应内容，并打开门闸唤醒所有等待协程"""
global _gate_probing global _gate_probing
delay = 1.0 # 初始退避 1 秒 delay = 0.5 # 固定间隔 500ms
max_delay = 30.0 # 最大退避 30 秒
attempt = 0 attempt = 0
while True: while True:
@@ -104,8 +103,7 @@ async def _probe_until_recover(llm: BaseChatModel, system_prompt: str, user_mess
log.info("AI 接口恢复，门闸打开，第{}次探测成功", attempt) log.info("AI 接口恢复，门闸打开，第{}次探测成功", attempt)
return response.content return response.content
except Exception as e: except Exception as e:
log.warning("AI 接口仍不可用，第{}次探测失败(退避{}s): {}", attempt, delay, e) log.warning("AI 接口仍不可用，第{}次探测失败(间隔{}ms): {}", attempt, int(delay * 1000), e)
delay = min(delay * 2, max_delay)
async def ai_chat_json(llm: BaseChatModel, system_prompt: str, user_message: str, scene: Optional[str] = None) -> Any: async def ai_chat_json(llm: BaseChatModel, system_prompt: str, user_message: str, scene: Optional[str] = None) -> Any: