Stream agent execution, yielding tuples matching Pregel's format.
Delegates to RemoteGraph.astream (which handles messages-tuple
negotiation, SSE routing, and namespace parsing) and converts the raw
message dicts into LangChain message objects for the adapter.
astream(
self,
input: dict | Any,
*,
stream_mode: list[str] | None = None,
subgraphs: bool = False,
config: dict[str, Any] | None = None,
context: Any | None = None,
durability: str | None = None
) -> AsyncIterator[tuple[tuple[str, ...], str, Any]]| Name | Type | Description |
|---|---|---|
input* | dict | Any | The input to send (messages dict or Command). |
stream_mode | list[str] | None | Default: NoneStream modes to request. |
subgraphs | bool | Default: FalseWhether to stream subgraph events. |
config | dict[str, Any] | None | Default: NoneLangGraph config with |
context | Any | None | Default: NoneRuntime context (e.g. |
durability | str | None | Default: NoneIgnored (server manages durability). |