Method run

src/agent/opencode_agent/runner.py:618–720

Run OpenCode for *question* and return a benchmark result.

(self, question: str)

        )

    async def run(self, question: str) -> AgentResult:
        """Run OpenCode for *question* and return a benchmark result."""
        with agent_run_span(
            "opencode-agent", model=self._model_id, question=question
        ) as span:
            run_started = time.perf_counter()
            started_at = _dt.datetime.now(_dt.UTC).isoformat()

            cmd = [
                self._opencode_bin,
                "run",
                "--pure",
                "--format",
                "json",
                "--model",
                self._opencode_model,
                "--agent",
                self._agent_name,
                "--dir",
                str(self._run_dir),
                "--title",
                "AssetOpsBench",
            ]
            if self._attach:
                cmd.extend(["--attach", self._attach])
            if self._variant:
                cmd.extend(["--variant", self._variant])
            if self._thinking:
                cmd.append("--thinking")
            if self._dangerously_skip_permissions:
                cmd.append("--dangerously-skip-permissions")
            cmd.append(question)

            env = os.environ.copy()
            # The OpenCode subprocess should not expose host-side evaluation
            # output paths to file/bash tools. The Python wrapper persists the
            # trajectory after OpenCode exits, using the parent process env.
            env.pop("AGENT_TRAJECTORY_DIR", None)
            env.pop("SCENARIOS_DATA_DIR", None)
            env.update(self._env_overrides)
            env["OPENCODE_CONFIG_CONTENT"] = json.dumps(self._config)
            env.setdefault("OPENCODE_DISABLE_AUTOUPDATE", "true")
            env.setdefault("NO_COLOR", "1")

            _log.info(
                "OpenCodeAgentRunner: starting query (model=%s, opencode_model=%s)",
                self._model_id,
                self._opencode_model,
            )
            proc = await asyncio.create_subprocess_exec(
                *cmd,
                cwd=str(self._run_dir),
                env=env,
                stdout=asyncio.subprocess.PIPE,
                stderr=asyncio.subprocess.PIPE,
            )
            try:
                stdout_b, stderr_b = await asyncio.wait_for(