Skip to content
beam-agents
GitHub

class

RunAgent

beam_agents.core.transform.RunAgent

RunAgent(agent: 'Agent', *, config: 'AgentConfig') -> 'None'

Docstring

Run agent as a keyed stateful transform over a pre-keyed envelope stream.

src/beam_agents/core/transform.py:638

Members

1 declared on RunAgent

Introspected from the class itself. A member with no docstring is shown as having none rather than described from its name.

  • expand

    method

    expand(self, pcoll: 'beam.pvalue.PCollection') -> 'RunAgentOutputs'

    Wire the stateful agent DoFn and its four tagged outputs.

    Raises ValueError on non-KV input: Beam's stateful DoFn requires a keyed PCollection, and failing here beats failing on a worker.