SyncPregelLoop(
self,
input: Any | None,
*,
stream: StreamProtocol| 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] |
| trigger_to_nodes | Mapping[str, Sequence[str]] |
| durability | Durability |
| manager | None | AsyncParentRunManager | ParentRunManager |
| interrupt_after | All | Sequence[str] |
| interrupt_before | All | Sequence[str] |
| input_keys | str | Sequence[str] |
| output_keys | str | Sequence[str] |
| stream_keys | str | Sequence[str] |
| migrate_checkpoint | Callable[[Checkpoint], None] | None |
| retry_policy | Sequence[RetryPolicy] |
| cache_policy | CachePolicy | None |
| has_graph_lifecycle_callbacks | bool |