Method run_async

src/google/adk/tools/agent_tool.py:349–369

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

  @override
  async def run_async(
      self,
      *,
      args: dict[str, Any],
      tool_context: ToolContext,
  ) -> Any:
    input_schema = _get_input_schema(self.agent)
    if input_schema:
      try:
        node_input = input_schema.model_validate(args)
      except Exception as e:
        return f'Error validating input: {e}'
    else:
      node_input = args.get('request')

    try:
      return await tool_context.run_node(
          self.agent, node_input=node_input, use_sub_branch=True
      )
    except Exception as e:
      return f'Error running sub-agent: {e}'


class _DefaultTaskInput(BaseModel):