ghdZddlmZddlmZmZmZmZddlm Z m Z erddl m Z Gdde d Z Gd d e ZGd d eZGddeZeeefZdS)z6Module contains typedefs that are used with Runnables.) annotations) TYPE_CHECKINGAnyLiteralUnion) NotRequired TypedDict)Sequencec6eZdZUdZded< ded< ded<dS) EventDataz'Data associated with a streaming event.rinputoutputchunkN__name__ __module__ __qualname____doc____annotations__\/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/langchain_core/runnables/schema.pyr r sE11JJJKKKJJJrr F)totalcNeZdZUdZded< ded< ded< ded< d ed <d S) BaseStreamEventaStreaming event. Schema of a streaming event which is produced from the astream_events method. Example: .. code-block:: 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_idsNrrrrrr+su**XJJJ*KKK !   *)))   rrc*eZdZUdZded< ded<dS)StandardStreamEventzIA standard stream event that follows LangChain convention for event data.r datarnameNrrrrr#r#s1SSOOOIII<r-sJ<<""""""55555555555544444444)((((((