aretrieve_documents() — langchain Function Reference

Architecture documentation for the aretrieve_documents() function in multi_query.py from the langchain codebase.

Function python LangChainCore MessageInterface called by 1

Entity Profile

LangChainCore→ MessageInterface→ aretrieve_documents() — langchain Function Reference

Dependency Diagram

graph TD
  b1e3c34e_3ed6_3dee_9d90_294b4ca567cb["aretrieve_documents()"]
  cc26ec3b_70dc_5b02_e974_582867b22f34["MultiQueryRetriever"]
  b1e3c34e_3ed6_3dee_9d90_294b4ca567cb -->|defined in| cc26ec3b_70dc_5b02_e974_582867b22f34
  437f73d9_6841_a790_7045_3311a114243f["_aget_relevant_documents()"]
  437f73d9_6841_a790_7045_3311a114243f -->|calls| b1e3c34e_3ed6_3dee_9d90_294b4ca567cb
  style b1e3c34e_3ed6_3dee_9d90_294b4ca567cb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/langchain_classic/retrievers/multi_query.py lines 139–162

    async def aretrieve_documents(
        self,
        queries: list[str],
        run_manager: AsyncCallbackManagerForRetrieverRun,
    ) -> list[Document]:
        """Run all LLM generated queries.

        Args:
            queries: query list
            run_manager: the callback handler to use

        Returns:
            List of retrieved Documents
        """
        document_lists = await asyncio.gather(
            *(
                self.retriever.ainvoke(
                    query,
                    config={"callbacks": run_manager.get_child()},
                )
                for query in queries
            ),
        )
        return [doc for docs in document_lists for doc in docs]