invoke() — langchain Function Reference

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

Function python LangChainCore Runnables calls 1 called by 1

Entity Profile

LangChainCore→ Runnables→ invoke() — langchain Function Reference

Dependency Diagram

graph TD
  d7e07719_d9d2_93df_a94c_b665406d2538["invoke()"]
  b484cd3a_bbd0_4ff6_dc8c_3fc1ac219bca["EnsembleRetriever"]
  d7e07719_d9d2_93df_a94c_b665406d2538 -->|defined in| b484cd3a_bbd0_4ff6_dc8c_3fc1ac219bca
  846fcd62_7844_5645_0197_3c181518377e["rank_fusion()"]
  846fcd62_7844_5645_0197_3c181518377e -->|calls| d7e07719_d9d2_93df_a94c_b665406d2538
  846fcd62_7844_5645_0197_3c181518377e["rank_fusion()"]
  d7e07719_d9d2_93df_a94c_b665406d2538 -->|calls| 846fcd62_7844_5645_0197_3c181518377e
  style d7e07719_d9d2_93df_a94c_b665406d2538 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/langchain_classic/retrievers/ensemble.py lines 89–123

    def invoke(
        self,
        input: str,
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> list[Document]:
        from langchain_core.callbacks import CallbackManager

        config = ensure_config(config)
        callback_manager = CallbackManager.configure(
            config.get("callbacks"),
            None,
            verbose=kwargs.get("verbose", False),
            inheritable_tags=config.get("tags", []),
            local_tags=self.tags,
            inheritable_metadata=config.get("metadata", {}),
            local_metadata=self.metadata,
        )
        run_manager = callback_manager.on_retriever_start(
            None,
            input,
            name=config.get("run_name") or self.get_name(),
            **kwargs,
        )
        try:
            result = self.rank_fusion(input, run_manager=run_manager, config=config)
        except Exception as e:
            run_manager.on_retriever_error(e)
            raise
        else:
            run_manager.on_retriever_end(
                result,
                **kwargs,
            )
            return result