track_pending_interrupts(
graph_stream: AsyncIterator[Any],
pending: list[Interrupt]
) -> | Name | Type | Description |
|---|---|---|
graph_stream* | AsyncIterator[Any] | |
pending* | list[Interrupt] |
Pass through a graph stream while recording its active interrupts.
LangGraph's updates.__interrupt__ payload is the authoritative active
set for the current invocation. Unlike checkpoint task history, it does
not retain a parallel sibling after that sibling has been answered.
A multi-mode LangGraph stream containing updates.
Mutable output list containing the interrupts observed during this invocation, deduplicated by id.