@@ -138,17 +138,23 @@ async def wrapper(
138138 ** kwargs ,
139139 ):
140140 yield event
141+ event_metadata = f"| agent_name: { event .author } , user_id: { user_id } , session_id: { session_id } , invocation_id: { event .invocation_id } "
141142 if event .get_function_calls ():
142143 for function_call in event .get_function_calls ():
143- logger .debug (f"Function call: { function_call } " )
144+ logger .debug (f"Function call: { function_call } { event_metadata } " )
145+ elif event .get_function_responses ():
146+ for function_response in event .get_function_responses ():
147+ logger .debug (
148+ f"Function response: { function_response } { event_metadata } "
149+ )
144150 elif (
145151 event .content is not None
146152 and event .content .parts
147153 and event .content .parts [0 ].text is not None
148154 and len (event .content .parts [0 ].text .strip ()) > 0
149155 ):
150156 final_output = event .content .parts [0 ].text
151- logger .debug (f"Event output: { final_output } " )
157+ logger .debug (f"Event output: { final_output } { event_metadata } " )
152158
153159 post_run_process (self )
154160
@@ -492,17 +498,13 @@ async def event_generator():
492498 yield event
493499
494500 async for event in event_generator ():
495- if event .get_function_calls ():
496- for function_call in event .get_function_calls ():
497- logger .debug (f"Function call: { function_call } " )
498- elif (
501+ if (
499502 event .content is not None
500503 and event .content .parts
501504 and event .content .parts [0 ].text is not None
502505 and len (event .content .parts [0 ].text .strip ()) > 0
503506 ):
504507 final_output = event .content .parts [0 ].text
505- logger .debug (f"Event output: { final_output } " )
506508 except LlmCallsLimitExceededError as e :
507509 logger .warning (f"Max number of llm calls limit exceeded: { e } " )
508510 final_output = ""
0 commit comments