This commit is contained in:
yumoqing 2026-02-13 17:55:32 +08:00
parent bf909d2b62
commit 418b1c782b

View File

@ -90,7 +90,6 @@ class IndustrialSkillEngine:
self.state = {"current_skill": None, "history": [], "pending_params": []} self.state = {"current_skill": None, "history": [], "pending_params": []}
async def write_output(self, data): async def write_output(self, data):
debug(f'-----------write_output() called: {data=}')
await self.task_queue.put(data) await self.task_queue.put(data)
# --- 1. 工业级初始化:依赖检查与索引 --- # --- 1. 工业级初始化:依赖检查与索引 ---
@ -150,7 +149,7 @@ class IndustrialSkillEngine:
try: try:
env = os.environ.copy() env = os.environ.copy()
env["SKILL_CONTEXT"] = skill_name env["SKILL_CONTEXT"] = skill_name
intput_str = json.dumps(params, ensure_ascii=False) debug(f'running: {command=}, cwd={self.registry[skill_name]["root"]},{params_str=}')
res = await run_subprocess(command, cwd=self.registry[skill_name]["root"], res = await run_subprocess(command, cwd=self.registry[skill_name]["root"],
env=env, env=env,
input_str=params_str, input_str=params_str,