aadd_documents() — langchain Function Reference

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

Function python LangChainCore Runnables

Entity Profile

LangChainCore→ Runnables→ aadd_documents() — langchain Function Reference

Dependency Diagram

graph TD
  8ef95604_bdb2_eec9_3235_0aaf60a866ef["aadd_documents()"]
  4269aa92_b131_014d_4134_d396f7de1f62["InMemoryVectorStore"]
  8ef95604_bdb2_eec9_3235_0aaf60a866ef -->|defined in| 4269aa92_b131_014d_4134_d396f7de1f62
  style 8ef95604_bdb2_eec9_3235_0aaf60a866ef fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/tests/unit_tests/indexes/test_indexing.py lines 88–108

    async def aadd_documents(
        self,
        documents: Sequence[Document],
        *,
        ids: Sequence[str] | None = None,
        **kwargs: Any,
    ) -> list[str]:
        if ids and len(ids) != len(documents):
            msg = f"Expected {len(ids)} ids, got {len(documents)} documents."
            raise ValueError(msg)

        if not ids:
            msg = "This is not implemented yet."
            raise NotImplementedError(msg)

        for _id, document in zip(ids, documents, strict=False):
            if _id in self.store and not self.permit_upserts:
                msg = f"Document with uid {_id} already exists in the store."
                raise ValueError(msg)
            self.store[_id] = document
        return list(ids)