Ask a question to get started
Enter to send•Shift+Enter new line
Check if the graph should be interrupted based on current state.
should_interrupt( checkpoint: Checkpoint, interrupt_nodes: All | Sequence[str], tasks: Iterable[PregelExecutableTask] ) -> list[PregelExecutableTask]