- _prepareNextTasks<Nn, Cc>(checkpoint, processes, channels, forExecution): [Checkpoint, PregelTaskDescription[]]
类型参数
- Nn extends StrRecord<string, PregelNode<any, any>>
- Cc extends StrRecord<string, BaseChannel<unknown, unknown, unknown>>
参数
- checkpoint: ReadonlyCheckpoint
- processes: Nn
- channels: Cc
- forExecution: false
返回值 [Checkpoint, PregelTaskDescription[]]
- _prepareNextTasks<Nn, Cc>(checkpoint, processes, channels, forExecution): [Checkpoint, PregelExecutableTask<keyof Nn, keyof Cc>[]]
类型参数
- Nn extends StrRecord<string, PregelNode<any, any>>
- Cc extends StrRecord<string, BaseChannel<unknown, unknown, unknown>>
参数
- checkpoint: ReadonlyCheckpoint
- processes: Nn
- channels: Cc
- forExecution: true
返回值 [Checkpoint, PregelExecutableTask<keyof Nn, keyof Cc>[]]