Method _enqueue_event

src/google/adk/workflow/_node_runner.py:319–339

Enrich and enqueue event to the session. Suppresses output if output is delegated via use_as_output (since the child already emitted it), but preserves other event details. Pending deltas stay in ctx for _flush_output_and_deltas.

(self, event: Event, ctx: Context)

        _validate_state_entry(ctx.state._schema, key, value)

  async def _enqueue_event(self, event: Event, ctx: Context) -> None:
    """Enrich and enqueue event to the session.

    Suppresses output if output is delegated via use_as_output (since the child
    already emitted it), but preserves other event details. Pending deltas stay
    in ctx for _flush_output_and_deltas.
    """
    if event.output is not None and ctx._output_delegated:
      if not _has_non_output_content(event):
        return
      event = event.model_copy(update={"output": None})

    self._enrich_event(event, ctx)
    if not event.partial:
      self._flush_deltas(event, ctx)
    await ctx._invocation_context._enqueue_event(event)

    if event.output is not None:
      ctx._output_emitted = True
    if event.node_info.message_as_output:
      ctx._output_delegated = True

  async def _flush_output_and_deltas(self, ctx: Context) -> None:
    """Emit deferred output and/or unflushed state/artifact deltas."""