Class●Since v0.6

PregelLoop

PregelLoop(
  self,
  input: Any | None,
  *,
  stream: StreamProtocol

Constructors

constructor

__init__

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
has_graph_lifecycle_callbacks	bool