@@ -610,11 +610,14 @@ def _func_tool_for_provider(self) -> ToolSet | None:
610610 return None
611611 return self .req .func_tool
612612
613- def _simple_print_message_role (self , tag : str = "" ):
614- roles = []
615- for message in self .run_context .messages :
616- roles .append (message .role )
617- logger .debug (f"{ tag } RunCtx.messages -> [{ len (roles )} ] { ',' .join (roles )} " )
613+ def _simple_print_message_role (self , tag : str , messages : list ):
614+ roles = [m .role for m in messages ]
615+ n = len (roles )
616+ if n > 10 :
617+ summary = "," .join (roles [:4 ]) + ",...," + "," .join (roles [- 4 :])
618+ else :
619+ summary = "," .join (roles )
620+ logger .debug (f"{ tag } messages -> [{ n } ] { summary } " )
618621
619622 def follow_up (
620623 self ,
@@ -713,11 +716,11 @@ async def step(self):
713716 # provider call. Persistent compaction is owned by the conversation /
714717 # memory layer.
715718 token_usage = self .req .conversation .token_usage if self .req .conversation else 0
716- self ._simple_print_message_role ("[BefCompact]" )
719+ self ._simple_print_message_role ("[BefCompact]" , self . run_context . messages )
717720 self ._provider_messages = await self .request_context_manager .process (
718721 self .run_context .messages , trusted_token_usage = token_usage
719722 )
720- self ._simple_print_message_role ("[AftCompact]" )
723+ self ._simple_print_message_role ("[AftCompact]" , self . _provider_messages )
721724
722725 async for llm_response in self ._iter_llm_responses_with_fallback ():
723726 if llm_response .is_chunk :
0 commit comments