blob42/langchain
1
0
Fork 0
forked from Archives/langchain
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add async call to APIChain. (#2583) (#2644)

Browse Source 
Co-authored-by: Yan <32036413+Yan-Zero@users.noreply.github.com>
This commit is contained in:
Ankush Gola 2023-04-10 01:28:16 +02:00 committed by GitHub
parent e56673c7f9
commit c51753250d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
langchain/chains/api/base.py
View File

@ -81,6 +81,26 @@ class APIChain(Chain):
) )
return {self.output_key: answer} return {self.output_key: answer}
async def _acall(self, inputs: Dict[str, str]) -> Dict[str, str]:
question = inputs[self.question_key]
api_url = await self.api_request_chain.apredict(
question=question, api_docs=self.api_docs
)
self.callback_manager.on_text(
api_url, color="green", end="\n", verbose=self.verbose
)
api_response = await self.requests_wrapper.aget(api_url)
self.callback_manager.on_text(
api_response, color="yellow", end="\n", verbose=self.verbose
)
answer = await self.api_answer_chain.apredict(
question=question,
api_docs=self.api_docs,
api_url=api_url,
api_response=api_response,
)
return {self.output_key: answer}
@classmethod @classmethod
def from_llm_and_api_docs( def from_llm_and_api_docs(
cls, cls,