g3fiWdZddlmZddlmZmZmZddlmZm Z erddl m Z Gdde d Z Gd d e Z Gd d e ZGdde ZeezZy)z?Module contains typedefs that are used with `Runnable` objects.) annotations) TYPE_CHECKINGAnyLiteral) NotRequired TypedDict)Sequencec@eZdZUdZded< ded< ded< ded<y) EventDataz'Data associated with a streaming event.rinputzNotRequired[BaseException]erroroutputchunkN__name__ __module__ __qualname____doc____annotations__]/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_core/runnables/schema.pyr r s41 J &% K Jrr F)totalcLeZdZUdZded< ded< ded< ded< d ed <y ) BaseStreamEventaStreaming 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_idsNrrrrrr2sG+Z J* K ! *)  rrc(eZdZUdZded< ded<y)StandardStreamEventzIA standard stream event that follows LangChain convention for event data.r datarnameNrrrrr#r#sS O I>rr#c4eZdZUdZded< ded< ded<y) CustomStreamEventz(Custom stream event created by the user.zLiteral['on_custom_event']rrr%rr$Nrrrrr'r's 2 &% I* ILrr'N)r __future__rtypingrrrtyping_extensionsrrcollections.abcr r rr#r' StreamEventrrrr-s_E"..4(" "JiiiX ?/ ? M M"$55 r