ainvoke() — langchain Function Reference

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

Function python LangChainCore Runnables calls 1 called by 1

Entity Profile

LangChainCore→ Runnables→ ainvoke() — langchain Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

libs/langchain/langchain_classic/retrievers/ensemble.py lines 126–164

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

        config = ensure_config(config)
        callback_manager = AsyncCallbackManager.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 = await callback_manager.on_retriever_start(
            None,
            input,
            name=config.get("run_name") or self.get_name(),
            **kwargs,
        )
        try:
            result = await self.arank_fusion(
                input,
                run_manager=run_manager,
                config=config,
            )
        except Exception as e:
            await run_manager.on_retriever_error(e)
            raise
        else:
            await run_manager.on_retriever_end(
                result,
                **kwargs,
            )
            return result