INNER CODE UNIT · Python

_aretrieve

junruxiong/IncarnaMind · convo_qa_chain.py:225

    async def _aretrieve(
        self,
        question_list: List[str],
        inputs: Dict[str, Any],
        run_manager: Optional[AsyncCallbackManagerForChainRun] = None,
    ) -> Dict[str, Any]:
        num_query = len(question_list)
        accepts_run_manager = (
            "run_manager" in inspect.signature(self._get_docs).parameters
        )

        total_results = {}
        for question in question_list:
            docs_dict = (
                await self._aget_docs(
                    question, inputs, num_query=num_query, run_manager=run_manager
                )
                if accepts_run_manager

View source record →