bugfix
This commit is contained in:
parent
1a69fba507
commit
042e43f9b2
@ -249,10 +249,16 @@ class IndustrialSkillEngine:
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
env = self.request._run_ns
|
env = self.request._run_ns
|
||||||
user_reply = await env.session_getvalue(sessionkey)
|
cnt = 0
|
||||||
while not user_reply:
|
while True:
|
||||||
await asyncio.sleep(0.5)
|
await asyncio.sleep(0.5)
|
||||||
user_reply = await env.session_getvalue(sessionkey)
|
user_reply = await env.session_getvalue(sessionkey)
|
||||||
|
if user_reply:
|
||||||
|
break
|
||||||
|
if cnt >= 60:
|
||||||
|
debug('env.session_getvalue("{sessionkey}") get None')
|
||||||
|
cnt = 0
|
||||||
|
cnt += 1
|
||||||
debug(f'{user_reply=}===============================')
|
debug(f'{user_reply=}===============================')
|
||||||
prompt = f"{user_prompt}\n补充输入:{user_reply}"
|
prompt = f"{user_prompt}\n补充输入:{user_reply}"
|
||||||
await self._run(prompt, context=context, is_retry=True)
|
await self._run(prompt, context=context, is_retry=True)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user