skillagent/skillengine.py

@@ -14,7 +14,7 @@ from appPublic.dictObject import DictObject
 from appPublic.log import info, debug, error, exception
 from appPublic.jsonConfig import getConfig
 from appPublic.uniqueID import getID
-from appPublic.zmqapi import zmq_subscribe
+from appPublic.zmqapi import zmq_subcribe
 
 # 配置审计日志
 
@@ -264,7 +264,7 @@ class IndustrialSkillEngine:
 			})
 			env = self.request._run_ns
 			cnt = 0
-			user_reply = await zmq_subscribe(sessionkey)
+			user_reply = await zmq_subcribe(sessionkey)
 			debug(f'{user_reply=}===============================')
 			prompt = f"{user_prompt}\n补充输入：{user_reply}"
 			await self._run(prompt, context=context, is_retry=True)