on_retriever_end() — langchain Function Reference

Architecture documentation for the on_retriever_end() function in manager.py from the langchain codebase.

Function python Observability CallbackManager calls 2 called by 1

Entity Profile

Observability→ CallbackManager→ on_retriever_end() — langchain Function Reference

Dependency Diagram

graph TD
  aabfd114_e57d_6e2c_c23d_b09e44659725["on_retriever_end()"]
  dd85546d_8151_094a_5f31_46a5d816ebef["AsyncCallbackManagerForRetrieverRun"]
  aabfd114_e57d_6e2c_c23d_b09e44659725 -->|defined in| dd85546d_8151_094a_5f31_46a5d816ebef
  4d0370de_fc12_b768_9ed2_62d72893e01a["on_retriever_end()"]
  4d0370de_fc12_b768_9ed2_62d72893e01a -->|calls| aabfd114_e57d_6e2c_c23d_b09e44659725
  4d0370de_fc12_b768_9ed2_62d72893e01a["on_retriever_end()"]
  aabfd114_e57d_6e2c_c23d_b09e44659725 -->|calls| 4d0370de_fc12_b768_9ed2_62d72893e01a
  3a243d21_72d1_dca9_f7be_acbb482b9f86["ahandle_event()"]
  aabfd114_e57d_6e2c_c23d_b09e44659725 -->|calls| 3a243d21_72d1_dca9_f7be_acbb482b9f86
  style aabfd114_e57d_6e2c_c23d_b09e44659725 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/callbacks/manager.py lines 1254–1275

    async def on_retriever_end(
        self, documents: Sequence[Document], **kwargs: Any
    ) -> None:
        """Run when the retriever ends running.

        Args:
            documents: The retrieved documents.
            **kwargs: Additional keyword arguments.

        """
        if not self.handlers:
            return
        await ahandle_event(
            self.handlers,
            "on_retriever_end",
            "ignore_retriever",
            documents,
            run_id=self.run_id,
            parent_run_id=self.parent_run_id,
            tags=self.tags,
            **kwargs,
        )