Ask a question to get started
Enter to send•Shift+Enter new line
SubgraphRunStream( self, mux: StreamMux, *, path: tuple[str, ...]
GraphRunStream
_SubgraphRunStreamMixin
Drive the run to completion and return the final state.
Drive the run to completion, then return whether it was
Drive the run to completion, then return interrupt payloads.
Stop the run early.
Iterate multiple projections in arrival order, yielding (name, item).
(name, item)
Sync handle for a discovered subgraph (extends GraphRunStream).
