from typing import Annotatedfrom beeai_sdk.a2a.extensions import TrajectoryExtensionServer, TrajectoryExtensionSpec@server.agent()async def my_agent( input: Message, context: RunContext, trajectory: Annotated[TrajectoryExtensionServer, TrajectoryExtensionSpec()]): yield trajectory.trajectory_metadata( title="Planning", content="Analyzing the user request to determine the best approach..." ) # Do work yield trajectory.trajectory_metadata( title="Execution", content="Processing data with temperature=0.7" ) yield "Final result"