fix: close MCP sessions in text chat runner

This commit is contained in:
Abhishek Kumar 2026-06-12 14:56:38 +05:30
parent 1f1149f4d5
commit 5bf7518829

View file

@ -636,8 +636,10 @@ async def execute_text_chat_pending_turn(
"Transportless text chat pipeline failed while closing run {}",
workflow_run_id,
)
await engine.close_mcp_sessions()
await engine.cleanup()
raise
await engine.close_mcp_sessions()
await engine.cleanup()
gathered_context = await engine.get_gathered_context()