_complete_retrieval_run() — langchain Function Reference

Architecture documentation for the _complete_retrieval_run() function in core.py from the langchain codebase.

Function python Observability Tracers calls 1

Entity Profile

Observability→ Tracers→ _complete_retrieval_run() — langchain Function Reference

Dependency Diagram

graph TD
  4454c837_cb28_523a_8f70_6ca390bfb957["_complete_retrieval_run()"]
  70348e44_de0f_ccb4_c06a_8453289ed93e["_TracerCore"]
  4454c837_cb28_523a_8f70_6ca390bfb957 -->|defined in| 70348e44_de0f_ccb4_c06a_8453289ed93e
  66392709_99c4_1a2e_dfac_aed34eebe5f5["_get_run()"]
  4454c837_cb28_523a_8f70_6ca390bfb957 -->|calls| 66392709_99c4_1a2e_dfac_aed34eebe5f5
  style 4454c837_cb28_523a_8f70_6ca390bfb957 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/tracers/core.py lines 511–526

    def _complete_retrieval_run(
        self,
        documents: Sequence[Document],
        run_id: UUID,
    ) -> Run:
        """Update a retrieval run with outputs and end time."""
        retrieval_run = self._get_run(run_id, run_type="retriever")
        if getattr(retrieval_run, "outputs", None) is None:
            retrieval_run.outputs = {}
        if not retrieval_run.extra.get("__omit_auto_outputs", False):
            cast("dict[str, Any]", retrieval_run.outputs).update(
                {"documents": documents}
            )
        retrieval_run.end_time = datetime.now(timezone.utc)
        retrieval_run.events.append({"name": "end", "time": retrieval_run.end_time})
        return retrieval_run