async def _reinitialize_session(self):
    """Reinitializes the session when connection is lost."""
    # Close the old session and create a new one
    await self._mcp_session_manager.close()
    await self._mcp_session_manager.create_session()
Reinitializes the session when connection is lost.
src/google/adk/tools/mcp_tool/mcp_tool.py