langchain Architecture Docs
Home / Function/ test_event_stream_with_retriever() — langchain Function Reference

test_event_stream_with_retriever() — langchain Function Reference

Architecture documentation for the test_event_stream_with_retriever() function in test_runnable_events_v2.py from the langchain codebase.

Function python LangChainCore Runnables calls 1

Entity Profile

Dependency Diagram

graph TD
  91b7dc94_26ca_fef2_44ae_d92e7ed6d34f["test_event_stream_with_retriever()"]
  33c02978_2077_5819_7048_bc2a81e80625["test_runnable_events_v2.py"]
  91b7dc94_26ca_fef2_44ae_d92e7ed6d34f -->|defined in| 33c02978_2077_5819_7048_bc2a81e80625
  716d2a5e_dc8e_3cae_e044_b56b06bee655["_collect_events()"]
  91b7dc94_26ca_fef2_44ae_d92e7ed6d34f -->|calls| 716d2a5e_dc8e_3cae_e044_b56b06bee655
  style 91b7dc94_26ca_fef2_44ae_d92e7ed6d34f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/tests/unit_tests/runnables/test_runnable_events_v2.py lines 1223–1271

async def test_event_stream_with_retriever() -> None:
    """Test the event stream with a retriever."""
    retriever = HardCodedRetriever(
        documents=[
            Document(
                page_content="hello world!",
                metadata={"foo": "bar"},
            ),
            Document(
                page_content="goodbye world!",
                metadata={"food": "spare"},
            ),
        ]
    )
    events = await _collect_events(
        retriever.astream_events({"query": "hello"}, version="v2")
    )
    _assert_events_equal_allow_superset_metadata(
        events,
        [
            {
                "data": {
                    "input": {"query": "hello"},
                },
                "event": "on_retriever_start",
                "metadata": {},
                "name": "HardCodedRetriever",
                "run_id": "",
                "parent_ids": [],
                "tags": [],
            },
            {
                "data": {
                    "output": [
                        Document(page_content="hello world!", metadata={"foo": "bar"}),
                        Document(
                            page_content="goodbye world!", metadata={"food": "spare"}
                        ),
                    ]
                },
                "event": "on_retriever_end",
                "metadata": {},
                "name": "HardCodedRetriever",
                "run_id": "",
                "parent_ids": [],
                "tags": [],
            },
        ],
    )

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does test_event_stream_with_retriever() do?
test_event_stream_with_retriever() is a function in the langchain codebase, defined in libs/core/tests/unit_tests/runnables/test_runnable_events_v2.py.
Where is test_event_stream_with_retriever() defined?
test_event_stream_with_retriever() is defined in libs/core/tests/unit_tests/runnables/test_runnable_events_v2.py at line 1223.
What does test_event_stream_with_retriever() call?
test_event_stream_with_retriever() calls 1 function(s): _collect_events.

Analyze Your Own Codebase

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

Try Supermodel Free