Function _prepareNextTasks
- _prepareNextTasks<Nn, Cc>(checkpoint, processes, channels, forExecution): [Checkpoint, PregelTaskDescription[]]
Type Parameters
- Nn extends StrRecord<string, PregelNode<any, any>>
- Cc extends StrRecord<string, BaseChannel<unknown, unknown, unknown>>
Parameters
- checkpoint: ReadonlyCheckpoint
- processes: Nn
- channels: Cc
- forExecution: false
Returns [Checkpoint, PregelTaskDescription[]]
- _prepareNextTasks<Nn, Cc>(checkpoint, processes, channels, forExecution): [Checkpoint, PregelExecutableTask<keyof Nn, keyof Cc>[]]
Type Parameters
- Nn extends StrRecord<string, PregelNode<any, any>>
- Cc extends StrRecord<string, BaseChannel<unknown, unknown, unknown>>
Parameters
- checkpoint: ReadonlyCheckpoint
- processes: Nn
- channels: Cc
- forExecution: true
Returns [Checkpoint, PregelExecutableTask<keyof Nn, keyof Cc>[]]