class
StreamAgent
beam_agents.core.agent.StreamAgent
StreamAgent(*args, **kwargs)Docstring
The agent-authoring runtime contract: one async entry point.
An activation performs all of its work through ctx — reading and
writing memory, calling the model, running read-only tools, staging side
effects via ctx.act(...), and emitting outputs via ctx.emit(...).
This is a runtime contract only; it defines no prompt templating or
orchestration DSL.
Members
1 declared on StreamAgent
Introspected from the class itself. A member with no docstring is shown as having none rather than described from its name.
activate
method
activate(self, ctx: 'AgentContext') -> 'None'
Run one activation against
ctx.Everything the agent does — memory writes, staged intents, model calls, the emitted output — goes through
ctxand is *staged*, not applied: the runtime commits it atomically with the Beam bundle only if this coroutine returns normally (correctness invariant 1). Raising mutates nothing and routes the element to.errors.