angee.agents_runtime_pydantic.runner

pydantic-ai implementation of the runtime-neutral persisted session runner.

PydanticAISessionRunner

class PydanticAISessionRunner(SessionRunner)

Execute one bounded turn with pydantic-ai and return neutral state.

run_turn

def run_turn(session: Any, turn: Any, *, deferred_results: list[Mapping[str,
                                                                        Any]],
             emit: SessionUpdateSink,
             heartbeat: SessionHeartbeat) -> TurnOutcome

Bridge the workflow's synchronous task into pydantic-ai's async loop.