SyncPregelLoop(
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],
trigger_to_nodes: Mapping[str, Sequence[str]],
durability: Durability,
manager: None | AsyncParentRunManager | ParentRunManager = None,
interrupt_after: All | Sequence[str] = EMPTY_SEQ,
interrupt_before: All | Sequence[str] = EMPTY_SEQ,
input_keys: str | Sequence[str] = EMPTY_SEQ,
output_keys: str | Sequence[str] = EMPTY_SEQ,
stream_keys: str | Sequence[str] = EMPTY_SEQ,
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] |
| 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 |
Tasks to execute in this step. If already attempted, may contain an error.