Method run_node

src/google/adk/agents/context.py:411–565

Executes a node dynamically. This method allows a node within a workflow to trigger the run of another node (or a callable that can be built into a node) and asynchronously wait for its result. The dynamically executed node becomes a child run of the current node in the workflow.

(
      self,
      node: NodeLike,
      node_input: Any = None,
      *,
      use_as_output: bool = False,
      run_id: str | None = None,
      use_sub_branch: bool = False,
      override_branch: str | None = None,
      override_isolation_scope: str | None = None,
      raise_on_wait: bool = False,
  )

    return ctx_with_proxy

  async def run_node(
      self,
      node: NodeLike,
      node_input: Any = None,
      *,
      use_as_output: bool = False,
      run_id: str | None = None,
      use_sub_branch: bool = False,
      override_branch: str | None = None,
      override_isolation_scope: str | None = None,
      raise_on_wait: bool = False,
  ) -> Any:
    """Executes a node dynamically.

    This method allows a node within a workflow to trigger the run of
    another node (or a callable that can be built into a node) and
    asynchronously wait for its result. The dynamically executed node becomes
    a child run of the current node in the workflow.

    IMPORTANT: Always ``await`` this method directly. Wrapping it in
    ``asyncio.create_task()`` means the task runs unsupervised — errors
    are silently swallowed and the task is not cancelled if the parent
    node is interrupted (e.g. via HITL).

    Args:
      node: The node to be executed. This can be a BaseNode instance or a
        callable that can be built into a node.
      node_input: The input data to be passed to the dynamically executed node.
        Defaults to None.
      use_as_output: If True, the dynamic node's output is used as the
        calling node's output. The calling node's own output event is
        suppressed to avoid duplication.
      run_id: An optional custom run ID for the dynamic node execution.
        If not provided, a default run ID is generated. Useful for
        correlating events across runs.
      use_sub_branch: If True, the dynamic node will be executed in a sub-branch
        to isolate its state and events from the main branch.
      override_branch: An optional branch to use instead of parent's branch.

    Returns:
      The output of the dynamically executed node, once it finishes executing.
    """

    if not self._node_rerun_on_resume:
      raise ValueError(
          'A node must have rerun_on_resume=True. Reason is that dynamically'
          ' scheduled nodes might be interrupted, and the workflow'
          ' wakes-up/re-runs the parent node, so it can get the child node'
          ' response.'
      )

    from ..workflow.utils._workflow_graph_utils import build_node  # pylint: disable=g-import-not-at-top

    built_node = build_node(node)

    from ..agents.base_agent import BaseAgent

    if isinstance(node, BaseAgent) and isinstance(built_node, BaseAgent):