Exécution asynchrone

from agentl.aio import AsyncHost, AsyncRuntime, Limits

host = AsyncHost()

@host.sensor("service.status")
async def status():
    async with session.get(STATUS_URL) as resp:
        return resp.status

@host.tool("restart", idempotent=True)
async def restart(service):
    async with session.post(f"{API}/restart/{service}") as resp:
        return {"status": resp.status}

host.approver = ask_operator            # sync ou async

rt = AsyncRuntime(agent, host, llm, limits=Limits(tool_timeout=10))
await rt.run(max_ticks=8)
print(rt.runtime.trace.render())

Limits(
    max_concurrent_tools=8,     # au-delà, l’appel attend son tour : contre-pression
    max_concurrent_llm=4,
    max_concurrent_reads=None,  # None = pas de borne
    tool_timeout=10,
    llm_timeout=30,
    read_timeout=5,
    human_timeout=None,
    inbox_capacity=100,         # messages en attente par agent
)

task = asyncio.create_task(rt.run(max_ticks=100))
...
rt.cancel()          # ou task.cancel()

from agentl.aio import AsyncSociety

society = AsyncSociety(program.agents,
                       hosts={"analyst": analyst_host, "responder": responder_host},
                       limits=Limits(max_concurrent_tools=4, inbox_capacity=50))
await society.run(max_ticks=6)
print(society.render_traces())