Apply writes from a set of tasks (usually the tasks from a Pregel step) to the checkpoint and channels, and return managed values writes to be applied externally.
apply_writes(
checkpoint: Checkpoint,
channels: Mapping[str, BaseChannel],
tasks: Iterable[WritesProtocol],
get_next_version: GetNextVersion | None,
trigger_to_nodes: Mapping[str, Sequence[str]]
) -> set[str]| Name | Type | Description |
|---|---|---|
checkpoint* | Checkpoint | The checkpoint to update. |
channels* | Mapping[str, BaseChannel] | The channels to update. |
tasks* | Iterable[WritesProtocol] | The tasks to apply writes from. |
get_next_version* | GetNextVersion | None | Optional function to determine the next version of a channel. |
trigger_to_nodes* | Mapping[str, Sequence[str]] | Mapping of channel names to the set of nodes that can be triggered by updates to that channel. |