SubgraphRunStream(
self,
mux: StreamMux,
values_transformer: ValuesTransformer,
*,
path: tuple[GraphRunStream_SubgraphRunStreamMixinDrive the run to completion, then return interrupt payloads.
Sync handle for a discovered subgraph (extends GraphRunStream).