| Name | Type |
|---|---|
| submit | weakref.ref[Submit] |
| put_writes | weakref.ref[Callable[[str, Sequence[tuple[str, Any]]], None]] |
| use_astream | bool |
| node_finished | Callable[[str], None] | None |
| node_error_handler_map | Mapping[str, str] | None |
| schedule_error_handler | Callable[[PregelExecutableTask, BaseException], PregelExecutableTask | None] | None |
| aschedule_error_handler | Callable[[PregelExecutableTask, BaseException], Awaitable[PregelExecutableTask | None]] | None |
Responsible for executing a set of Pregel tasks concurrently, committing their writes, yielding control to caller when there is output to emit, and interrupting other tasks if appropriate.
