langchain Architecture Docs
Home / File/ event_stream.py — langchain Source File

event_stream.py — langchain Source File

Architecture documentation for event_stream.py, a python file in the langchain codebase. 19 imports, 0 dependents.

File python CoreAbstractions Serialization 19 imports 4 functions 2 classes

Entity Profile

Dependency Diagram

graph LR
  4f8b46c6_9bea_256a_d764_90863752ddf6["event_stream.py"]
  a327e534_84f6_5308_58ca_5727d5eda0cf["asyncio"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> a327e534_84f6_5308_58ca_5727d5eda0cf
  69e1d8cc_6173_dcd0_bfdf_2132d8e1ce56["contextlib"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 69e1d8cc_6173_dcd0_bfdf_2132d8e1ce56
  2a7f66a7_8738_3d47_375b_70fcaa6ac169["logging"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 2a7f66a7_8738_3d47_375b_70fcaa6ac169
  8e2034b7_ceb8_963f_29fc_2ea6b50ef9b3["typing"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 8e2034b7_ceb8_963f_29fc_2ea6b50ef9b3
  91721f45_4909_e489_8c1f_084f8bd87145["typing_extensions"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 91721f45_4909_e489_8c1f_084f8bd87145
  7e64d143_ea36_1c73_4897_1d0ae1757b5b["langchain_core.callbacks.base"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 7e64d143_ea36_1c73_4897_1d0ae1757b5b
  d758344f_537f_649e_f467_b9d7442e86df["langchain_core.messages"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> d758344f_537f_649e_f467_b9d7442e86df
  ac2a9b92_4484_491e_1b48_ec85e71e1d58["langchain_core.outputs"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> ac2a9b92_4484_491e_1b48_ec85e71e1d58
  2ceb1686_0f8c_8ae0_36d1_7c0b702fda1c["langchain_core.runnables"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 2ceb1686_0f8c_8ae0_36d1_7c0b702fda1c
  2079f0e4_f3be_a6ad_7bb7_1f09a33f1ec3["langchain_core.runnables.schema"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 2079f0e4_f3be_a6ad_7bb7_1f09a33f1ec3
  81c04601_d095_a27d_4af1_55e771bb2b6b["langchain_core.runnables.utils"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 81c04601_d095_a27d_4af1_55e771bb2b6b
  20dd0fea_aa37_d877_66c8_eb36d8a53545["langchain_core.tracers._streaming"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 20dd0fea_aa37_d877_66c8_eb36d8a53545
  00303315_016c_bd4c_b122_eb71e173b0b6["langchain_core.tracers.log_stream"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> 00303315_016c_bd4c_b122_eb71e173b0b6
  dd98e19e_1fed_98d3_ef00_32b32b2e4e5c["langchain_core.tracers.memory_stream"]
  4f8b46c6_9bea_256a_d764_90863752ddf6 --> dd98e19e_1fed_98d3_ef00_32b32b2e4e5c
  style 4f8b46c6_9bea_256a_d764_90863752ddf6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

"""Internal tracer to power the event stream API."""

from __future__ import annotations

import asyncio
import contextlib
import logging
from typing import (
    TYPE_CHECKING,
    Any,
    TypedDict,
    TypeVar,
    cast,
)

from typing_extensions import NotRequired, override

from langchain_core.callbacks.base import AsyncCallbackHandler, BaseCallbackManager
from langchain_core.messages import AIMessageChunk, BaseMessage, BaseMessageChunk
from langchain_core.outputs import (
    ChatGenerationChunk,
    GenerationChunk,
    LLMResult,
)
from langchain_core.runnables import ensure_config
from langchain_core.runnables.schema import (
    CustomStreamEvent,
    EventData,
    StandardStreamEvent,
    StreamEvent,
)
from langchain_core.runnables.utils import (
    Input,
    Output,
    _RootEventFilter,
)
from langchain_core.tracers._streaming import _StreamingCallbackHandler
from langchain_core.tracers.log_stream import (
    LogStreamCallbackHandler,
    RunLog,
    _astream_log_implementation,
)
from langchain_core.tracers.memory_stream import _MemoryStream
from langchain_core.utils.aiter import aclosing
from langchain_core.utils.uuid import uuid7

if TYPE_CHECKING:
    from collections.abc import AsyncIterator, Iterator, Sequence
    from uuid import UUID

    from langchain_core.documents import Document
    from langchain_core.runnables import Runnable, RunnableConfig
    from langchain_core.tracers.log_stream import LogEntry

logger = logging.getLogger(__name__)


class RunInfo(TypedDict):
    """Information about a run.

// ... (1041 more lines)

Domain

Subdomains

Functions

Classes

Dependencies

  • asyncio
  • collections.abc
  • contextlib
  • langchain_core.callbacks.base
  • langchain_core.documents
  • langchain_core.messages
  • langchain_core.outputs
  • langchain_core.runnables
  • langchain_core.runnables.schema
  • langchain_core.runnables.utils
  • langchain_core.tracers._streaming
  • langchain_core.tracers.log_stream
  • langchain_core.tracers.memory_stream
  • langchain_core.utils.aiter
  • langchain_core.utils.uuid
  • logging
  • typing
  • typing_extensions
  • uuid

Source

Frequently Asked Questions

What does event_stream.py do?
event_stream.py is a source file in the langchain codebase, written in python. It belongs to the CoreAbstractions domain, Serialization subdomain.
What functions are defined in event_stream.py?
event_stream.py defines 4 function(s): _assign_name, _astream_events_implementation_v1, _astream_events_implementation_v2, collections.
What does event_stream.py depend on?
event_stream.py imports 19 module(s): asyncio, collections.abc, contextlib, langchain_core.callbacks.base, langchain_core.documents, langchain_core.messages, langchain_core.outputs, langchain_core.runnables, and 11 more.
Where is event_stream.py in the architecture?
event_stream.py is located at libs/core/langchain_core/tracers/event_stream.py (domain: CoreAbstractions, subdomain: Serialization, directory: libs/core/langchain_core/tracers).

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free