PregelLoop( self, input: Any | None, *, stream: StreamProtocol | None, config: RunnableConfig, store: BaseStore | None, cache: BaseCache | None, checkpointer: BaseCheckpointSaver | None, nodes: Mapping[str, PregelNode], specs: Mapping[str, BaseChannel | ManagedValueSpec], input_keys: str | Sequence[str], output_keys: str | Sequence[str], stream_keys: str | Sequence[str], trigger_to_nodes: Mapping[str, Sequence[str]], durability: Durability, interrupt_after: All | Sequence[str] = EMPTY_SEQ, interrupt_before: All | Sequence[str] = EMPTY_SEQ, manager: None | AsyncParentRunManager | ParentRunManager = None, migrate_checkpoint: Callable[[Checkpoint], None] | None = None, retry_policy: Sequence[RetryPolicy] = (), cache_policy: CachePolicy | None = None )| Name | Type |
|---|---|
| input | Any | None |
| stream | StreamProtocol | None |
| config | RunnableConfig |
| store | BaseStore | None |
| cache | BaseCache | None |
| checkpointer | BaseCheckpointSaver | None |
| nodes | Mapping[str, PregelNode] |
| specs | Mapping[str, BaseChannel | ManagedValueSpec] |
| input_keys | str | Sequence[str] |
| output_keys | str | Sequence[str] |
| stream_keys | str | Sequence[str] |
| trigger_to_nodes | Mapping[str, Sequence[str]] |
| durability | Durability |
| interrupt_after | All | Sequence[str] |
| interrupt_before | All | Sequence[str] |
| manager | None | AsyncParentRunManager | ParentRunManager |
| migrate_checkpoint | Callable[[Checkpoint], None] | None |
| retry_policy | Sequence[RetryPolicy] |
| cache_policy | CachePolicy | None |