Handle an event on the async lane.
Called when the run ends normally (sync lane).
Called when the run ends normally (async lane).
Called when the run ends with an error (sync lane).
Called when the run ends with an error (async lane).
Schedule a coroutine tied to this transformer's lifecycle.
Capture values events as a drainable stream of state snapshots.
Provides the run.values projection. run.output,
run.interrupted and run.interrupts are tracked directly
by the run stream and do not depend on this transformer.
Native transformer ā projection keys are exposed as direct
attributes on the run stream (e.g. run.values).
Only values events at the run's own level are captured; snapshots
from deeper subgraphs are left in the main event log but excluded
from the projection. "Own level" is defined by scope, which
stream_events(version="v3") / astream_events(version="v3") populate from the caller's
checkpoint namespace so that a nested stream_events(version="v3") call still
sees its own root snapshots.
