PregelLoop

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
)