Method _create_child_context

src/google/adk/workflow/_node_runner.py:190–240

Create a child Context for the node, inheriting from parent. If prior_output or prior_interrupt_ids were provided at construction (resume scenario), pre-populates ctx with state from the previous run.

(
      self,
      resume_inputs: dict[str, Any] | None,
      attempt_count: int = 1,
  )

    return True

  def _create_child_context(
      self,
      resume_inputs: dict[str, Any] | None,
      attempt_count: int = 1,
  ) -> Context:
    """Create a child Context for the node, inheriting from parent.

    If prior_output or prior_interrupt_ids were provided at
    construction (resume scenario), pre-populates ctx with state
    from the previous run.
    """
    from ..agents.context import Context

    ic = self._parent_ctx._invocation_context
    base_branch = (
        self._override_branch
        if self._override_branch is not None
        else ic.branch
    )

    if self._use_sub_branch:
      segment = f"{self._node.name}@{self._run_id}"
      branch = f"{base_branch}.{segment}" if base_branch else segment
      ic = ic.model_copy(update={"branch": branch})
    elif self._override_branch is not None:
      ic = ic.model_copy(update={"branch": self._override_branch})
    else:
      ic = ic.model_copy()

    ctx = Context(
        ic,
        parent_ctx=self._parent_ctx,
        node=self._node,
        run_id=self._run_id,
        resume_inputs=resume_inputs,
        use_as_output=self._use_as_output,
        attempt_count=attempt_count,
    )

    # override the inherited isolation_scope when explicitly set.
    if self._override_isolation_scope is not None:
      ctx.isolation_scope = self._override_isolation_scope

    # Carry forward state from a previous run (resume scenario).
    if self._prior_output is not None:
      ctx._output_value = self._prior_output
      ctx._output_emitted = True
    if self._prior_interrupt_ids:
      ctx._interrupt_ids.update(self._prior_interrupt_ids)

    return ctx

  async def _execute_node(
      self,