Method model_copy

src/google/adk/workflow/_node.py:177–188

Clones the node with updated fields.

(
      self, *, update: dict[str, Any] | None = None, deep: bool = False
  )

  @override
  def model_copy(
      self, *, update: dict[str, Any] | None = None, deep: bool = False
  ) -> Any:
    """Clones the node with updated fields."""
    copied = super().model_copy(update=update, deep=deep)

    if copied.parallel_worker:
      worker_node = copied.model_copy(update={"parallel_worker": False})
      copied._inner_node = parallel_worker_lib._ParallelWorker(node=worker_node)
      copied.rerun_on_resume = copied._inner_node.rerun_on_resume

    return copied

  async def run_node_impl(
      self, *, ctx: Context, node_input: Any