This commit is contained in:
yumoqing 2026-02-13 18:11:55 +08:00
parent 418b1c782b
commit 61f09d3691

View File

@ -46,6 +46,7 @@ async def run_subprocess(command, cwd, env, input_str=None, timeout=30.0):
try: try:
# 启动子进程 # 启动子进程
# stdout/stderr 设置为 PIPE 对应原来的 capture_output=True # stdout/stderr 设置为 PIPE 对应原来的 capture_output=True
env['PATH'] = f'{cwd}{env["PATH"]}'
process = await asyncio.create_subprocess_shell( process = await asyncio.create_subprocess_shell(
command, command,
stdout=asyncio.subprocess.PIPE, stdout=asyncio.subprocess.PIPE,
@ -205,7 +206,6 @@ class IndustrialSkillEngine:
if not data: if not data:
debug('End Data') debug('End Data')
break; break;
debug(f'{data=}, {type(data)=}')
yield json.dumps(data, ensure_ascii=False) + '\n' yield json.dumps(data, ensure_ascii=False) + '\n'
await asyncio.sleep(0.1) await asyncio.sleep(0.1)