more typos

This commit is contained in:
Eugene Yurtsev
2025-03-19 11:48:31 -04:00
parent f97802eed5
commit 67a16bec53
2 changed files with 4 additions and 0 deletions
@@ -2006,6 +2006,7 @@ class Pregel(PregelProtocol):
interrupt_after=interrupt_after_,
manager=run_manager,
debug=debug,
triggers_to_nodes=self.trigger_to_node,
) as loop:
# create runner
runner = PregelRunner(
+3
View File
@@ -897,6 +897,7 @@ class SyncPregelLoop(PregelLoop, ContextManager):
stream_keys: Union[str, Sequence[str]] = EMPTY_SEQ,
input_model: Optional[Type[BaseModel]] = None,
debug: bool = False,
triggers_to_nodes: Optional[Mapping[str, Sequence[str]]] = None,
) -> None:
super().__init__(
input,
@@ -913,6 +914,7 @@ class SyncPregelLoop(PregelLoop, ContextManager):
interrupt_before=interrupt_before,
manager=manager,
debug=debug,
triggers_to_nodes=triggers_to_nodes,
)
self.stack = ExitStack()
if checkpointer:
@@ -1055,6 +1057,7 @@ class AsyncPregelLoop(PregelLoop, AsyncContextManager):
interrupt_before=interrupt_before,
manager=manager,
debug=debug,
triggers_to_nodes=triggers_to_nodes,
)
self.stack = AsyncExitStack()
if checkpointer: