Function _execute_bash_sync

tutorials/14_bash_engine_deep_dive.py:504–556

同步执行命令，支持超时 — 源码 bash.rs:102-165 超时控制的关键: - Rust 用 tokio::time::timeout 包装 command.output() - Python 用 subprocess.run(timeout=...) - 超时后返回 interrupted=True + 特定错误消息 - 超时不会 kill 进程！只是放弃等待。 （Rust 的 tokio 版本在 drop future 时会清理子进程）

(
    inp: BashCommandInput,
    sandbox_status: SandboxStatus,
    cwd: Path,
)

def _execute_bash_sync(
    inp: BashCommandInput,
    sandbox_status: SandboxStatus,
    cwd: Path,
) -> BashCommandOutput:
    """同步执行命令，支持超时 — 源码 bash.rs:102-165

    超时控制的关键:
    - Rust 用 tokio::time::timeout 包装 command.output()
    - Python 用 subprocess.run(timeout=...)
    - 超时后返回 interrupted=True + 特定错误消息
    - 超时不会 kill 进程！只是放弃等待。
      （Rust 的 tokio 版本在 drop future 时会清理子进程）
    """
    cmd_args, env = prepare_command(inp.command, cwd, sandbox_status)

    timeout_seconds = inp.timeout / 1000.0 if inp.timeout else None

    try:
        result = subprocess.run(
            cmd_args,
            capture_output=True,
            cwd=str(cwd),
            env=env,
            timeout=timeout_seconds,
        )
        stdout = result.stdout.decode("utf-8", errors="replace")
        stderr = result.stderr.decode("utf-8", errors="replace")

        # 解释返回码 — 源码 bash.rs:140-146
        return_code_interpretation = None
        if result.returncode != 0:
            return_code_interpretation = f"exit_code:{result.returncode}"

        return BashCommandOutput(
            stdout=stdout,
            stderr=stderr,
            interrupted=False,
            sandbox_status=sandbox_status,
            return_code_interpretation=return_code_interpretation,
            no_output_expected=(not stdout.strip() and not stderr.strip()),
        )

    except subprocess.TimeoutExpired:
        # 超时处理 — 源码 bash.rs:112-130
        # 注意: 返回的消息格式是固定的，模型会解析这个消息
        return BashCommandOutput(
            stderr=f"Command exceeded timeout of {inp.timeout} ms",
            interrupted=True,
            sandbox_status=sandbox_status,
            return_code_interpretation="timeout",
            no_output_expected=True,
        )


# ============================================================