Ask a question to get started
Enter to send•Shift+Enter new line
Produce "task_result" events for stream_mode=debug.
map_debug_task_results( task_tup: tuple[PregelExecutableTask, Sequence[tuple[str, Any]]], stream_keys: str | Sequence[str] ) -> Iterator[TaskResultPayload]