bugfix
This commit is contained in:
parent
8f140ffd2d
commit
df8654ef23
@ -81,7 +81,7 @@ class IndustrialSkillEngine:
|
|||||||
await self.task_queue.put(data)
|
await self.task_queue.put(data)
|
||||||
|
|
||||||
# --- 1. 工业级初始化:依赖检查与索引 ---
|
# --- 1. 工业级初始化:依赖检查与索引 ---
|
||||||
def boot(self, refresh=False):
|
async def boot(self, refresh=False):
|
||||||
env = self.request._run_ns
|
env = self.request._run_ns
|
||||||
userid = await env.get_user()
|
userid = await env.get_user()
|
||||||
key = f'skillregister_{userid}'
|
key = f'skillregister_{userid}'
|
||||||
@ -194,7 +194,7 @@ class IndustrialSkillEngine:
|
|||||||
# --- 5. 主运行接口 ---
|
# --- 5. 主运行接口 ---
|
||||||
async def run(self, user_prompt: str, context=None, is_retry=False):
|
async def run(self, user_prompt: str, context=None, is_retry=False):
|
||||||
# 如果是重试,跳过技能选择
|
# 如果是重试,跳过技能选择
|
||||||
self.boot()
|
await self.boot()
|
||||||
if not is_retry:
|
if not is_retry:
|
||||||
await self.write_output({
|
await self.write_output({
|
||||||
"status": "PROCESSING",
|
"status": "PROCESSING",
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user