Stop a running agent
(session_id: str)
| 318 | |
| 319 | |
| 320 | async def stop_agent(session_id: str): |
| 321 | """Stop a running agent""" |
| 322 | await deep_research_manager.stop(session_id) |
| 323 | if session_id in agent_runners: |
| 324 | await agent_runners[session_id].stop() |
| 325 | del agent_runners[session_id] |
| 326 | if session_id in agent_tasks: |
| 327 | agent_tasks[session_id].cancel() |
| 328 | del agent_tasks[session_id] |
| 329 | |
| 330 | session_manager.update_session(session_id, {'status': 'stopped'}) |
| 331 | await connection_manager.send_to_session(session_id, { |
| 332 | 'type': 'status', |
| 333 | 'status': 'stopped' |
| 334 | }) |
| 335 | |
| 336 | |
| 337 | async def send_input(session_id: str, data: Dict[str, Any]): |
no test coverage detected