Log events yielded from the runner.
(
self, *, invocation_context: InvocationContext, event: Event
)
| 104 | |
| 105 | @override |
| 106 | async def on_event_callback( |
| 107 | self, *, invocation_context: InvocationContext, event: Event |
| 108 | ) -> Optional[Event]: |
| 109 | """Log events yielded from the runner.""" |
| 110 | self._log(f"📢 EVENT YIELDED") |
| 111 | self._log(f" Event ID: {event.id}") |
| 112 | self._log(f" Author: {event.author}") |
| 113 | self._log(f" Content: {self._format_content(event.content)}") |
| 114 | self._log(f" Final Response: {event.is_final_response()}") |
| 115 | |
| 116 | if event.get_function_calls(): |
| 117 | func_calls = [fc.name for fc in event.get_function_calls()] |
| 118 | self._log(f" Function Calls: {func_calls}") |
| 119 | |
| 120 | if event.get_function_responses(): |
| 121 | func_responses = [fr.name for fr in event.get_function_responses()] |
| 122 | self._log(f" Function Responses: {func_responses}") |
| 123 | |
| 124 | if event.long_running_tool_ids: |
| 125 | self._log(f" Long Running Tools: {list(event.long_running_tool_ids)}") |
| 126 | |
| 127 | return None |
| 128 | |
| 129 | @override |
| 130 | async def after_run_callback( |
nothing calls this directly
no test coverage detected