Method run_async

src/google/adk/tools/mcp_tool/mcp_tool.py:286–359

(
      self, *, args: dict[str, Any], tool_context: ToolContext
  )

  @override
  async def run_async(
      self, *, args: dict[str, Any], tool_context: ToolContext
  ) -> Any:
    if isinstance(self._require_confirmation, Callable):
      args_to_call = args.copy()
      try:
        signature = inspect.signature(self._require_confirmation)
        valid_params = set(signature.parameters.keys())
        has_kwargs = any(
            param.kind == inspect.Parameter.VAR_KEYWORD
            for param in signature.parameters.values()
        )

        # Detect context parameter by type or fallback to 'tool_context' name
        context_param = (
            find_context_parameter(self._require_confirmation) or "tool_context"
        )
        if context_param in valid_params or has_kwargs:
          args_to_call[context_param] = tool_context

        # Filter args_to_call only if there's no **kwargs
        if not has_kwargs:
          # Add context param to valid_params if it was added to args_to_call
          if context_param in args_to_call:
            valid_params.add(context_param)
          args_to_call = {
              k: v for k, v in args_to_call.items() if k in valid_params
          }
      except ValueError:
        args_to_call = args

      require_confirmation = await self._invoke_callable(
          self._require_confirmation, args_to_call
      )
    else:
      require_confirmation = bool(self._require_confirmation)

    if require_confirmation:
      if not tool_context.tool_confirmation:
        tool_context.request_confirmation(
            hint=(
                f"Please approve or reject the tool call {self.name}() by"
                " responding with a FunctionResponse with an expected"
                " ToolConfirmation payload."
            ),
        )
        return {
            "error": (
                "This tool call requires confirmation, please approve or"
                " reject."
            )
        }
      elif not tool_context.tool_confirmation.confirmed:
        return {"error": "This tool call is rejected."}

    if not is_feature_enabled(FeatureName._MCP_GRACEFUL_ERROR_HANDLING):  # pylint: disable=protected-access
      # Pre-fix behavior: exceptions bubble up to the agent runner.
      return await super().run_async(args=args, tool_context=tool_context)