_acall() — langchain Function Reference

Architecture documentation for the _acall() function in base.py from the langchain codebase.

Function python AgentOrchestration ClassicChains calls 2

Entity Profile

AgentOrchestration→ ClassicChains→ _acall() — langchain Function Reference

Dependency Diagram

graph TD
  0bfde7b9_784b_2dd7_04f2_aad7c49096aa["_acall()"]
  5aa1201d_23fd_f122_acb5_563cb1cc3cb3["BaseQAWithSourcesChain"]
  0bfde7b9_784b_2dd7_04f2_aad7c49096aa -->|defined in| 5aa1201d_23fd_f122_acb5_563cb1cc3cb3
  2df9f284_e3a5_fb7b_a200_c20ea1a10d39["_aget_docs()"]
  0bfde7b9_784b_2dd7_04f2_aad7c49096aa -->|calls| 2df9f284_e3a5_fb7b_a200_c20ea1a10d39
  2c491715_4dce_6ca9_19b4_2181a298e783["_split_sources()"]
  0bfde7b9_784b_2dd7_04f2_aad7c49096aa -->|calls| 2c491715_4dce_6ca9_19b4_2181a298e783
  style 0bfde7b9_784b_2dd7_04f2_aad7c49096aa fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain/langchain_classic/chains/qa_with_sources/base.py lines 190–215

    async def _acall(
        self,
        inputs: dict[str, Any],
        run_manager: AsyncCallbackManagerForChainRun | None = None,
    ) -> dict[str, Any]:
        _run_manager = run_manager or AsyncCallbackManagerForChainRun.get_noop_manager()
        accepts_run_manager = (
            "run_manager" in inspect.signature(self._aget_docs).parameters
        )
        if accepts_run_manager:
            docs = await self._aget_docs(inputs, run_manager=_run_manager)
        else:
            docs = await self._aget_docs(inputs)  # type: ignore[call-arg]
        answer = await self.combine_documents_chain.arun(
            input_documents=docs,
            callbacks=_run_manager.get_child(),
            **inputs,
        )
        answer, sources = self._split_sources(answer)
        result: dict[str, Any] = {
            self.answer_key: answer,
            self.sources_answer_key: sources,
        }
        if self.return_source_documents:
            result["source_documents"] = docs
        return result