prepare_next_tasks(
checkpoint: Checkpoint,
pending_writes: list[PendingWrite],
processes:| Name | Type | Description |
|---|---|---|
checkpoint* | Checkpoint | The current checkpoint. |
pending_writes* | list[PendingWrite] | The list of pending writes. |
processes* | Mapping[str, PregelNode] | |
channels* | Mapping[str, BaseChannel] | |
managed* | ManagedValueMapping | |
config* | RunnableConfig | |
step* | int | |
for_execution* | bool | |
store | BaseStore | None | Default: None |
checkpointer | BaseCheckpointSaver | None | Default: None |
manager | None | ParentRunManager | AsyncParentRunManager | Default: None |
trigger_to_nodes | Mapping[str, Sequence[str]] | None | Default: None |
updated_channels | set[str] | None | Default: None |
Prepare the set of tasks that will make up the next Pregel step.
The mapping of process names to PregelNode instances.
The mapping of channel names to BaseChannel instances.
The mapping of managed value names to functions.
The Runnable configuration.
The current step.
Whether the tasks are being prepared for execution.
An instance of BaseStore to make it available for usage within tasks.
Checkpointer instance used for saving checkpoints.
The parent run manager to use for the tasks.
Optional: Mapping of channel names to the set of nodes that are can be triggered by that channel.
Optional. Set of channel names that have been updated during the previous step. Using in conjunction with trigger_to_nodes to speed up the process of determining which nodes should be triggered in the next step.