test_aindexing_same_content() — langchain Function Reference

Architecture documentation for the test_aindexing_same_content() function in test_indexing.py from the langchain codebase.

Function python LangChainCore ApiManagement

Entity Profile

LangChainCore→ ApiManagement→ test_aindexing_same_content() — langchain Function Reference

Dependency Diagram

graph TD
  acb038ec_be1b_2e0b_2b8f_b9a4e7fff64b["test_aindexing_same_content()"]
  a9fb4c74_0865_0941_ade3_563a79762cee["test_indexing.py"]
  acb038ec_be1b_2e0b_2b8f_b9a4e7fff64b -->|defined in| a9fb4c74_0865_0941_ade3_563a79762cee
  style acb038ec_be1b_2e0b_2b8f_b9a4e7fff64b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/tests/unit_tests/indexing/test_indexing.py lines 108–149

async def test_aindexing_same_content(
    arecord_manager: InMemoryRecordManager, vector_store: InMemoryVectorStore
) -> None:
    """Indexing some content to confirm it gets added only once."""
    loader = ToyLoader(
        documents=[
            Document(
                page_content="This is a test document.",
            ),
            Document(
                page_content="This is another document.",
            ),
        ]
    )

    assert await aindex(
        loader,
        arecord_manager,
        vector_store,
        key_encoder="sha256",
    ) == {
        "num_added": 2,
        "num_deleted": 0,
        "num_skipped": 0,
        "num_updated": 0,
    }

    assert len(list(vector_store.store)) == 2

    for _ in range(2):
        # Run the indexing again
        assert await aindex(
            loader,
            arecord_manager,
            vector_store,
            key_encoder="sha256",
        ) == {
            "num_added": 0,
            "num_deleted": 0,
            "num_skipped": 2,
            "num_updated": 0,
        }