Unset sentinel value.
Tag to hide a node/edge from certain tracing/streaming environments.
Drop langgraph's internal seq:step:* bookkeeping tags.
seq:step:N tags are added internally to mark sequence steps; everything
else (user-supplied tags and any other framework tags) is kept. Returns the
surviving tags, or None if none remain. Shared by the messages and
tasks stream handlers so both surface the same tag set on their metadata.
Produce "task" events for stream_mode=debug.
Return True if the payload already wraps multiple writes from the same channel.
Folds task writes into a result dict and aggregates multiple writes to the same channel.
If the channel contains a single write, we record the write in the result dict as {channel: write}
If the channel contains multiple writes, we record the writes in the result dict as {channel: {'$writes': [write1, write2, ...]}}
Produce "task_result" events for stream_mode=debug.
Remove pregel-specific keys from the config.
Produce "checkpoint" events for stream_mode=debug.
Apply writes / subgraph states to tasks to be returned in a StateSnapshot.
Get colored text.
Get bolded text.
Base class for all channels.
Payload for a checkpoint event.
A Pregel task.
Snapshot of the state of the graph at the beginning of a step.
Payload for a task start event.
Payload for a task result event.
