​
marvin.engine.streaming

​
Functions

​
handle_agentlet_events

def handle_agentlet_events(agentlet: pydantic_ai.Agent, actor: Actor, run: AgentRun)
Run a PydanticAI agentlet and process its events through the Marvin event system. This function:
  1. Runs the agentlet’s iterator
  2. Processes all nodes and events from PydanticAI
  3. Converts them to Marvin events and yields them
Args: run: The agentlet run to process actor: The actor associated with this agentlet run Usage: agentlet = pydantic_ai.Agent(…) with agentlet.iter(msg) as run: async for event in handle_agentlet_events( actor=actor, run=run, tools=tools, end_turn_tools=end_turn_tools, ): yield event Yields: Marvin events derived from PydanticAI events
Parent Module: engine