diff --git a/skillagent/skillengine.py b/skillagent/skillengine.py index 6f66df4..712ca37 100644 --- a/skillagent/skillengine.py +++ b/skillagent/skillengine.py @@ -249,10 +249,16 @@ class IndustrialSkillEngine: } }) env = self.request._run_ns - user_reply = await env.session_getvalue(sessionkey) - while not user_reply: + cnt = 0 + while True: await asyncio.sleep(0.5) 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=}===============================') prompt = f"{user_prompt}\n补充输入:{user_reply}" await self._run(prompt, context=context, is_retry=True)