pip install "omnicoreagent[codemode]"

import asyncio
from omnicoreagent import OmniCoreAgent, ToolRegistry

tools = ToolRegistry()
ORDERS = {
    "A1": {"id": "A1", "status": "shipped", "days_in_transit": 9},
    "A2": {"id": "A2", "status": "shipped", "days_in_transit": 2},
    "A3": {"id": "A3", "status": "shipped", "days_in_transit": 12},
    "A4": {"id": "A4", "status": "open", "days_in_transit": 0},
}

@tools.register_tool("list_orders")
def list_orders(status: str) -> list:
    """List the IDs of the orders with a status: open or shipped."""
    return [order_id for order_id, order in ORDERS.items() if order["status"] == status]

@tools.register_tool("get_order")
def get_order(order_id: str) -> dict:
    """Get one order, with how many days it has been in transit."""
    return ORDERS[order_id]

async def main():
    agent = OmniCoreAgent(
        name="analyst",
        system_instruction="Answer questions about orders. Answer in plain text, in one sentence.",
        model_config={"provider": "openai", "model": "gpt-5.4-mini"},
        local_tools=tools,
        agent_config={
            "code_mode": {
                "enabled": True,
                "tools": ["list_orders", "get_order"],
                "max_tool_calls": 50,
            },
        },
    )
    result = await agent.run(
        "Which shipped orders have been in transit for more than 7 days? Use run_code."
    )
    print(result["response"])

    trajectory = await agent.get_trajectory(result["trace_id"])
    for step in trajectory["steps"]:
        for call in step["tool_calls"]:
            print("step", step["step"], "->", call["tool_name"], call["outcome"])
            if call["tool_name"] == "run_code":
                print(call["arguments"]["code"])
            for inner in call.get("code_calls", []):
                print("   ", inner["tool_call_id"], inner["tool_name"], inner["arguments"], inner["outcome"])
    await agent.cleanup()

asyncio.run(main())

Shipped orders in transit for more than 7 days are A1 (9 days) and A3 (12 days).
step 1 -> run_code success
shipped = list_orders(status='shipped')
result = []
for oid in shipped:
    order = get_order(order_id=oid)
    days = order.get('days_in_transit') if isinstance(order, dict) else None
    if days is not None and days > 7:
        result.append((oid, days))
result
    call_pJwGyluJODGpGR0On2C4ckaP.1 list_orders {'status': 'shipped'} success
    call_pJwGyluJODGpGR0On2C4ckaP.2 get_order {'order_id': 'A1'} success
    call_pJwGyluJODGpGR0On2C4ckaP.3 get_order {'order_id': 'A2'} success
    call_pJwGyluJODGpGR0On2C4ckaP.4 get_order {'order_id': 'A3'} success

import asyncio
from omnicoreagent import OmniCoreAgent, ToolRegistry
from omnicoreagent.governance import PolicyEffect, PolicyRule, build_default_policy

tools = ToolRegistry()
ORDERS = {"A1": 9, "A2": 2, "A3": 12}  # order ID -> days in transit
REFUNDED = []

@tools.register_tool("list_late_orders")
def list_late_orders(days: int) -> list:
    """List the IDs of shipped orders in transit for more than this many days."""
    return [order_id for order_id, age in ORDERS.items() if age > days]

@tools.register_tool("issue_refund")
def issue_refund(order_id: str) -> dict:
    """Refund an order in full."""
    REFUNDED.append(order_id)
    return {"order_id": order_id, "refunded": True}

policy = build_default_policy("interactive-dev")
policy.rules.ask.append(
    PolicyRule(rule_id="ask_before_refunds", effect=PolicyEffect.ASK,
               capability="tool.local.call", target={"tool_name": "issue_refund"})
)

async def main():
    agent = OmniCoreAgent(
        name="refunds",
        system_instruction="You handle late orders. Answer in plain text, in one sentence.",
        model_config={"provider": "openai", "model": "gpt-5.4-mini"},
        local_tools=tools,
        agent_config={
            "code_mode": {"enabled": True},
            "governance_config": {"enabled": True, "policy": policy},
        },
    )
    result = await agent.run(
        "Refund every order in transit for more than 7 days, with one run_code program."
    )
    while result["status"] == "awaiting_approval":
        for approval in result["approvals"]:
            print("waiting on:", approval["tool_name"], approval["tool_call_id"], approval["arguments"])
            await agent.resolve_approval(
                result["run_id"], approval["approval_id"], decision="approve", approver="alice"
            )
        result = await agent.resume(result["run_id"])
    print(result["status"], "-", result["response"])
    print("refunded:", REFUNDED)
    await agent.cleanup()

asyncio.run(main())

waiting on: issue_refund call_FaQpOBEjc27UQMHtdxCf15np.2 {'order_id': 'A1'}
waiting on: issue_refund call_FaQpOBEjc27UQMHtdxCf15np.3 {'order_id': 'A3'}
success - Refunded all in-transit orders over 7 days: A1 and A3.
refunded: ['A1', 'A3']