async def _reinitialize_session(self):
    """Reinitializes the session when connection is lost."""
    # Close the old session and clear cache
    await self._mcp_session_manager.close()
    self._session = await self._mcp_session_manager.create_session()

    # Tools will be reloaded on next get_tools call
Reinitializes the session when connection is lost.
src/google/adk/tools/mcp_tool/mcp_toolset.py