Method run

tests/harbor_echo_agent.py:36–56

(
        self,
        instruction: str,
        environment: BaseEnvironment,
        context: AgentContext,
    )

        return None

    async def run(
        self,
        instruction: str,
        environment: BaseEnvironment,
        context: AgentContext,
    ) -> None:
        text = f"{self._prefix}{instruction}"
        toks = list(range(1, len(text.split()) + 2))
        context.n_input_tokens = len(instruction.split())
        context.n_output_tokens = len(toks)
        context.rollout_details = [{
            "prompt_token_ids": [list(range(context.n_input_tokens))],
            "completion_token_ids": [toks],
            "logprobs": [[-0.1] * len(toks)],
        }]
        # write the completion to the agent dir so the host-side EvsysVerifier
        # (run by harbor) can score it
        logs_dir = getattr(self, "logs_dir", None)
        if logs_dir is not None:
            Path(logs_dir).mkdir(parents=True, exist_ok=True)
            (Path(logs_dir) / "completion.txt").write_text(text)