@@ -30,9 +30,11 @@ async def history_agent(create_server_with_agent) -> AsyncGenerator[tuple[Server
3030 """Agent that tests context.store.load_history() functionality."""
3131
3232 async def history_agent (input : Message , context : RunContext ) -> AsyncGenerator [RunYield ]:
33+ input .metadata = {"test" : "metadata" }
3334 await context .store (input )
3435 async for message in context .load_history ():
3536 message .role = Role .agent
37+ assert message .metadata == {"test" : "metadata" }
3638 yield message
3739 await context .store (message )
3840
@@ -58,14 +60,17 @@ async def test_agent_history(history_agent, subtests):
5860
5961 final_task = await get_final_task_from_stream (client .send_message (create_message (token , "first message" )))
6062 agent_messages = [msg .parts [0 ].root .text for msg in final_task .history ]
63+ assert all (msg .metadata == {"test" : "metadata" } for msg in final_task .history )
6164 assert agent_messages == ["first message" ]
6265
6366 final_task = await get_final_task_from_stream (client .send_message (create_message (token , "second message" )))
6467 agent_messages = [msg .parts [0 ].root .text for msg in final_task .history ]
68+ assert all (msg .metadata == {"test" : "metadata" } for msg in final_task .history )
6569 assert agent_messages == ["first message" , "first message" , "second message" ]
6670
6771 final_task = await get_final_task_from_stream (client .send_message (create_message (token , "third message" )))
6872 agent_messages = [msg .parts [0 ].root .text for msg in final_task .history ]
73+ assert all (msg .metadata == {"test" : "metadata" } for msg in final_task .history )
6974 assert agent_messages == [
7075 # first run
7176 "first message" ,
0 commit comments