Ask a question to get started
Enter to send•Shift+Enter new line
Map pending writes (a sequence of tuples (channel, value)) to output chunk.
map_output_updates( output_channels: str | Sequence[str], tasks: list[tuple[PregelExecutableTask, Sequence[tuple[str, Any]]]], cached: bool = False ) -> Iterator[dict[str, Any | dict[str, Any]]]
