Method close

src/google/adk/plugins/plugin_manager.py:324–371

Calls the close method on all registered plugins concurrently. If this manager was constructed with `skip_closing_plugins=True`, this method is a no-op so plugins owned by another component (e.g. a parent `Runner`) are not torn down while still in use. Raises: RuntimeError: I

(self)

    return None

  async def close(self) -> None:
    """Calls the close method on all registered plugins concurrently.

    If this manager was constructed with `skip_closing_plugins=True`, this
    method is a no-op so plugins owned by another component (e.g. a parent
    `Runner`) are not torn down while still in use.

    Raises:
      RuntimeError: If one or more plugins failed to close, containing
        details of all failures.
    """
    if self._skip_closing_plugins:
      logger.debug(
          "Skipping plugin close; plugins are owned by another component."
      )
      return
    exceptions = {}
    # We iterate sequentially to avoid creating new tasks which can cause issues
    # with some libraries (like anyio/mcp) that rely on task-local context.
    for plugin in self.plugins:
      try:
        if sys.version_info >= (3, 11):
          async with asyncio.timeout(self._close_timeout):
            await plugin.close()
        else:
          # For Python < 3.11, we use wait_for which creates a new task.
          # This might still cause issues with task-local contexts, but
          # asyncio.timeout is not available.
          await asyncio.wait_for(plugin.close(), timeout=self._close_timeout)
      except Exception as e:
        exceptions[plugin.name] = e
        if isinstance(e, (asyncio.TimeoutError, asyncio.CancelledError)):
          logger.warning(
              "Timeout/Cancelled while closing plugin: %s", plugin.name
          )
        else:
          logger.error(
              "Error during close of plugin %s: %s",
              plugin.name,
              e,
              exc_info=e,
          )

    if exceptions:
      error_summary = ", ".join(
          f"'{name}': {type(exc).__name__}" for name, exc in exceptions.items()
      )
      raise RuntimeError(f"Failed to close plugins: {error_summary}")