Method _run_node_loop

src/google/adk/workflow/_node_runner.py:263–273

Iterate node.run(), track events in context, and enqueue them.

(self, ctx: Context, node_input: Any)

      pass

  async def _run_node_loop(self, ctx: Context, node_input: Any) -> None:
    """Iterate node.run(), track events in context, and enqueue them."""
    from ..utils.context_utils import Aclosing

    logger.debug("node %s execute loop start.", ctx.node_path)
    async with Aclosing(self._node.run(ctx=ctx, node_input=node_input)) as agen:
      async for event in agen:
        self._track_event_in_context(event, ctx)
        await self._enqueue_event(event, ctx)

    logger.debug("node %s execute loop end.", ctx.node_path)

  async def _run_node_loop_with_timeout(
      self, ctx: Context, node_input: Any, timeout: float