Method run_interactive

src/harness/agentic_loop/loop.py:177–221

Interactive REPL mode. Reads tasks from stdin. Special commands: /plan — run task in plan mode (decompose → generate YAML plans → execute) exit — quit the loop

(self)

        return result

    def run_interactive(self) -> None:
        """Interactive REPL mode. Reads tasks from stdin.

        Special commands:
          /plan <task>  — run task in plan mode (decompose → generate YAML plans → execute)
          exit          — quit the loop
        """
        self._setup()
        print(
            "AgentSPEX Agentic Loop (type '/exit' to quit, '/plan <task>' for plan mode)"
        )

        while True:
            print()
            self.logger.rule()
            try:
                user_input = pt_prompt(
                    "> ", lexer=_SlashCommandLexer(), style=_PROMPT_STYLE
                ).strip()
            except (EOFError, KeyboardInterrupt):
                print("\nExiting.")
                break

            if user_input.lower() in ("/exit", "/quit", "/q"):
                break
            if not user_input:
                continue

            self.logger.rule()
            print()

            if user_input.startswith("/plan "):
                task = user_input[len("/plan ") :].strip()
                if not task:
                    print("Usage: /plan <task description>")
                    continue
                self.logger.event("user_message", {"content": user_input})
                result = self._run_plan_mode(task)
                self.logger.event("loop_end", self.session.get_usage_summary())
                continue

            self.session.add_user_message(user_input)
            self._inner_loop()

        self.logger.event("loop_end", self.session.get_usage_summary())

    def _setup(self) -> None:
        """Initialize MCP tools, orchestrator tools, plan generator, and system prompt."""