apply_writes(
checkpoint: Checkpoint,
channels: Mapping[str, BaseChannel],
tasks: Iterable| Name | Type | Description |
|---|---|---|
checkpoint* | Checkpoint | The checkpoint to update. |
channels* | Mapping[str, BaseChannel] | The channels to update. |
tasks* | Iterable[WritesProtocol] | |
get_next_version* | GetNextVersion | None | |
trigger_to_nodes* | Mapping[str, Sequence[str]] |
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.
The tasks to apply writes from.
Optional function to determine the next version of a channel.
Mapping of channel names to the set of nodes that can be triggered by updates to that channel.