test_runnable_events_v2.py — langchain Source File

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

File python CoreAbstractions RunnableInterface 30 imports 38 functions 4 classes

Entity Profile

CoreAbstractions→ RunnableInterface→ test_runnable_events_v2.py — langchain Source File

Dependency Diagram

graph LR
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d["test_runnable_events_v2.py"]
  a327e534_84f6_5308_58ca_5727d5eda0cf["asyncio"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> a327e534_84f6_5308_58ca_5727d5eda0cf
  614e7b9f_ed51_0780_749c_ff40b74963fc["inspect"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 614e7b9f_ed51_0780_749c_ff40b74963fc
  d76a28c2_c3ab_00a8_5208_77807a49449d["sys"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> d76a28c2_c3ab_00a8_5208_77807a49449d
  8dfa0cac_d802_3ccd_f710_43a5e70da3a5["uuid"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 8dfa0cac_d802_3ccd_f710_43a5e70da3a5
  cfe2bde5_180e_e3b0_df2b_55b3ebaca8e7["collections.abc"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> cfe2bde5_180e_e3b0_df2b_55b3ebaca8e7
  c990f2d7_9509_7cea_ca95_51ad57dbe5c6["functools"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> c990f2d7_9509_7cea_ca95_51ad57dbe5c6
  436f77bc_653d_0edb_555c_c2679d5a59ac["itertools"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 436f77bc_653d_0edb_555c_c2679d5a59ac
  8e2034b7_ceb8_963f_29fc_2ea6b50ef9b3["typing"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 8e2034b7_ceb8_963f_29fc_2ea6b50ef9b3
  120e2591_3e15_b895_72b6_cb26195e40a6["pytest"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 120e2591_3e15_b895_72b6_cb26195e40a6
  9eb3be64_a334_606b_b4bd_24e50a8c430d["blockbuster"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 9eb3be64_a334_606b_b4bd_24e50a8c430d
  6e58aaea_f08e_c099_3cc7_f9567bfb1ae7["pydantic"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 6e58aaea_f08e_c099_3cc7_f9567bfb1ae7
  91721f45_4909_e489_8c1f_084f8bd87145["typing_extensions"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> 91721f45_4909_e489_8c1f_084f8bd87145
  f3bc7443_c889_119d_0744_aacc3620d8d2["langchain_core.callbacks"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> f3bc7443_c889_119d_0744_aacc3620d8d2
  e8ec017e_6c91_4b34_675f_2a96c5aa9be6["langchain_core.callbacks.manager"]
  dff724fb_5c63_7e4e_e066_b4f58d4ab80d --> e8ec017e_6c91_4b34_675f_2a96c5aa9be6
  style dff724fb_5c63_7e4e_e066_b4f58d4ab80d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

"""Module that contains tests for runnable.astream_events API."""

import asyncio
import inspect
import sys
import uuid
from collections.abc import AsyncIterator, Callable, Iterable, Iterator, Sequence
from functools import partial
from itertools import cycle
from typing import (
    Any,
    cast,
)

import pytest
from blockbuster import BlockBuster
from pydantic import BaseModel
from typing_extensions import override

from langchain_core.callbacks import CallbackManagerForRetrieverRun, Callbacks
from langchain_core.callbacks.manager import (
    adispatch_custom_event,
)
from langchain_core.chat_history import BaseChatMessageHistory
from langchain_core.documents import Document
from langchain_core.language_models import FakeStreamingListLLM, GenericFakeChatModel
from langchain_core.messages import (
    AIMessage,
    AIMessageChunk,
    BaseMessage,
    HumanMessage,
    SystemMessage,
)
from langchain_core.prompt_values import ChatPromptValue
from langchain_core.prompts import ChatPromptTemplate, MessagesPlaceholder
from langchain_core.retrievers import BaseRetriever
from langchain_core.runnables import (
    ConfigurableField,
    Runnable,
    RunnableConfig,
    RunnableGenerator,
    RunnableLambda,
    chain,
    ensure_config,
)
from langchain_core.runnables.config import (
    get_async_callback_manager_for_config,
)
from langchain_core.runnables.history import RunnableWithMessageHistory
from langchain_core.runnables.schema import StreamEvent
from langchain_core.runnables.utils import Addable
from langchain_core.tools import tool
from langchain_core.utils.aiter import aclosing
from tests.unit_tests.runnables.test_runnable_events_v1 import (
    _assert_events_equal_allow_superset_metadata,
)
from tests.unit_tests.stubs import _any_id_ai_message, _any_id_ai_message_chunk


def _with_nulled_run_id(events: Sequence[StreamEvent]) -> list[StreamEvent]:
// ... (2851 more lines)

Domain

CoreAbstractions

Subdomains

RunnableInterface

Functions

Classes

Dependencies

asyncio
blockbuster
collections.abc
functools
inspect
itertools
langchain_core.callbacks
langchain_core.callbacks.manager
langchain_core.chat_history
langchain_core.documents
langchain_core.language_models
langchain_core.messages
langchain_core.prompt_values
langchain_core.prompts
langchain_core.retrievers
langchain_core.runnables
langchain_core.runnables.config
langchain_core.runnables.history
langchain_core.runnables.schema
langchain_core.runnables.utils
langchain_core.tools
langchain_core.utils.aiter
pydantic
pytest
sys
tests.unit_tests.runnables.test_runnable_events_v1
tests.unit_tests.stubs
typing
typing_extensions
uuid

Source

View on GitHub

Frequently Asked Questions

What does test_runnable_events_v2.py do?

test_runnable_events_v2.py is a source file in the langchain codebase, written in python. It belongs to the CoreAbstractions domain, RunnableInterface subdomain.

What functions are defined in test_runnable_events_v2.py?

test_runnable_events_v2.py defines 38 function(s): _collect_events, _with_nulled_run_id, test_astream_events_from_custom_runnable, test_astream_events_from_model, test_astream_with_model_in_chain, test_async_in_async_stream_lambdas, test_bad_parent_ids, test_break_astream_events, test_cancel_astream_events, test_chain_ordering, and 28 more.

What does test_runnable_events_v2.py depend on?

test_runnable_events_v2.py imports 30 module(s): asyncio, blockbuster, collections.abc, functools, inspect, itertools, langchain_core.callbacks, langchain_core.callbacks.manager, and 22 more.

Where is test_runnable_events_v2.py in the architecture?

test_runnable_events_v2.py is located at libs/core/tests/unit_tests/runnables/test_runnable_events_v2.py (domain: CoreAbstractions, subdomain: RunnableInterface, directory: libs/core/tests/unit_tests/runnables).

Analyze Your Own Codebase

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

Try Supermodel Free