D_iWSrSSKJr SSKJrJrJr SSKJrJ r \(aSSK J r "SS\ SS 9r "S S \ 5r "S S \ 5r"SS\ 5r\\-rg)z?Module contains typedefs that are used with `Runnable` objects.) annotations) TYPE_CHECKINGAnyLiteral) NotRequired TypedDict)SequencecH\rSrSr%SrS\S'S\S'S\S'S\S'S rg ) EventData z'Data associated with a streaming event.rinputzNotRequired[BaseException]erroroutputchunkN__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rY/home/james-whalen/.local/lib/python3.13/site-packages/langchain_core/runnables/schema.pyr r s41 J &% K Jrr F)totalcT\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S rg )BaseStreamEvent2aStreaming event. Schema of a streaming event which is produced from the `astream_events` method. Example: ```python from langchain_core.runnables import RunnableLambda async def reverse(s: str) -> str: return s[::-1] chain = RunnableLambda(func=reverse) events = [event async for event in chain.astream_events("hello")] # Will produce the following events # (where some fields have been omitted for brevity): [ { "data": {"input": "hello"}, "event": "on_chain_start", "metadata": {}, "name": "reverse", "tags": [], }, { "data": {"chunk": "olleh"}, "event": "on_chain_stream", "metadata": {}, "name": "reverse", "tags": [], }, { "data": {"output": "olleh"}, "event": "on_chain_end", "metadata": {}, "name": "reverse", "tags": [], }, ] ``` streventrun_idzNotRequired[list[str]]tagszNotRequired[dict[str, Any]]metadataz Sequence[str] parent_idsrNrrrrrr2sG+Z J* K ! *)  rrc0\rSrSr%SrS\S'S\S'Srg) StandardStreamEventzIA standard stream event that follows LangChain convention for event data.r datar namerNrrrrr'r'sS O I>rr'c<\rSrSr%SrS\S'S\S'S\S'S rg ) CustomStreamEventz(Custom stream event created by the user.zLiteral['on_custom_event']r!r r*rr)rNrrrrr,r,s 2 &% I* ILrr,N)r __future__rtypingrrrtyping_extensionsrrcollections.abcr r rr'r, StreamEventrrrr3s_E"..4(" "JiiiX ?/ ? M M"$55 r