AGENT CONTROL PLANE

import acp

# Initialize a recording session
acp.init(
    agent_version="v1.0.0",
    llm="gpt-4",
    seed=42,
    tools=["search", "calculator"]
)

# Instrument tools with automatic capture
@acp.tool(retry_policy=2)
def search(query: str) -> str:
    """Search results are automatically recorded."""
    return external_search_api(query)

# Wrap LLM calls
@acp.llm_wrapper
def call_llm(prompt: str) -> str:
    """Prompts and responses are captured."""
    return openai.chat(prompt)

# Run your agent logic
try:
    with acp.step("reason") as ctx:
        thought = call_llm("What should I do?")
        ctx.set_output("thought", thought)

    result = search("latest news")

    with acp.step("observe"):
        acp.update_memory([{"role": "tool", "content": result}])

finally:
    # Flush and close the trace
    acp.stop(reason="success")