Handle agent completion
(session_id: str, result: Dict[str, Any])
| 462 | |
| 463 | |
| 464 | async def on_agent_complete(session_id: str, result: Dict[str, Any]): |
| 465 | """Handle agent completion""" |
| 466 | session_manager.update_session(session_id, {'status': 'completed'}) |
| 467 | |
| 468 | if session_id in agent_runners: |
| 469 | del agent_runners[session_id] |
| 470 | if session_id in agent_tasks: |
| 471 | agent_tasks[session_id].cancel() |
| 472 | del agent_tasks[session_id] |
| 473 | |
| 474 | await connection_manager.send_to_session(session_id, { |
| 475 | 'type': 'complete', |
| 476 | 'result': result |
| 477 | }) |
| 478 | |
| 479 | |
| 480 | async def on_agent_error(session_id: str, error: Dict[str, Any]): |
no test coverage detected