_aget_relevant_documents() — langchain Function Reference

Architecture documentation for the _aget_relevant_documents() function in ensemble.py from the langchain codebase.

Function python LangChainCore ApiManagement calls 1

Entity Profile

LangChainCore→ ApiManagement→ _aget_relevant_documents() — langchain Function Reference

Dependency Diagram

graph TD
  b9cd53a7_287b_9106_31e2_728f202c29e2["_aget_relevant_documents()"]
  b484cd3a_bbd0_4ff6_dc8c_3fc1ac219bca["EnsembleRetriever"]
  b9cd53a7_287b_9106_31e2_728f202c29e2 -->|defined in| b484cd3a_bbd0_4ff6_dc8c_3fc1ac219bca
  f22e315b_c302_5414_8dd3_04bde7d630dd["arank_fusion()"]
  b9cd53a7_287b_9106_31e2_728f202c29e2 -->|calls| f22e315b_c302_5414_8dd3_04bde7d630dd
  style b9cd53a7_287b_9106_31e2_728f202c29e2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/langchain_classic/retrievers/ensemble.py lines 184–200

    async def _aget_relevant_documents(
        self,
        query: str,
        *,
        run_manager: AsyncCallbackManagerForRetrieverRun,
    ) -> list[Document]:
        """Asynchronously get the relevant documents for a given query.

        Args:
            query: The query to search for.
            run_manager: The callback handler to use.

        Returns:
            A list of reranked documents.
        """
        # Get fused result of the retrievers.
        return await self.arank_fusion(query, run_manager)