Function main

src/harness/agentic_loop/run_loop.py:100–158

()

def main():
    from harness.paths import ensure_runtime_dirs, init_run_env

    load_dotenv(find_dotenv(), override=True)
    ensure_runtime_dirs()
    _run_id, host_run = init_run_env("agentic_loop")
    args = parse_args()

    output_dir = (
        str(Path(args.output_dir).expanduser().resolve())
        if args.output_dir
        else str(host_run)
    )
    Path(output_dir).mkdir(parents=True, exist_ok=True)

    # Build MCP URL from env or args
    mcp_url = args.mcp_url
    if not mcp_url:
        hostname = os.getenv("MCP_HOSTNAME", "localhost")
        port = os.getenv("MCP_PORT", "7002")
        basepath = os.getenv("MCP_BASEPATH", "/mcp")
        mcp_url = f"http://{hostname}:{port}{basepath}"

    config = LoopConfig(
        model=args.model,
        mcp_url=mcp_url,
        max_turns=args.max_turns,
        temperature=args.temperature,
        output_dir=output_dir,
        plan_generator_model=args.plan_generator_model,
        plan_executor_model=args.plan_executor_model,
    )

    mcp_client = MCPClient(url=config.mcp_url)
    llm_client = LLMClient()

    # Mirror host layout inside the container: /workspace/outputs/<run_name>/.
    host_out = Path(output_dir)
    sandbox_out = f"outputs/{host_out.name}"

    logger = Logger(
        mcp_client,
        log_file=f"{sandbox_out}/agent_run.log",
        to_stdout=True,
        host_log_path=host_out / "agent_run.log",
        event_log_path=f"{sandbox_out}/agent_events.log",
        host_event_log_path=host_out / "agent_events.log",
    )

    loop = AgenticLoop(mcp_client, llm_client, config, logger)

    try:
        if args.task:
            result = loop.run(args.task, plan_mode=args.plan_mode)
            print(result)
        else:
            loop.run_interactive()
    finally: