CodeCow/Scrapegraph-ai
1
0
Fork 0
mirror of https://github.com/VinciGit00/Scrapegraph-ai.git synced 2026-07-12 21:01:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: generate answer node

Browse Source
This commit is contained in:
Marco Vinciguerra 2024-10-13 10:25:36 +02:00
parent 54b37bbda5
commit 431b2093be
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
scrapegraphai/nodes/generate_answer_node.py
View File

@ -57,7 +57,7 @@ class GenerateAnswerNode(BaseNode):
self.is_md_scraper = node_config.get("is_md_scraper", False) self.is_md_scraper = node_config.get("is_md_scraper", False)
self.additional_info = node_config.get("additional_info") self.additional_info = node_config.get("additional_info")
async def execute(self, state: dict) -> dict: def execute(self, state: dict) -> dict:
""" """
Executes the GenerateAnswerNode. Executes the GenerateAnswerNode.
@ -123,7 +123,7 @@ class GenerateAnswerNode(BaseNode):
chain = prompt | self.llm_model chain = prompt | self.llm_model
if output_parser: if output_parser:
chain = chain | output_parser chain = chain | output_parser
answer = await chain.ainvoke({"question": user_prompt}) answer = chain.invoke({"question": user_prompt})
state.update({self.output[0]: answer}) state.update({self.output[0]: answer})
return state return state
@ -143,7 +143,7 @@ class GenerateAnswerNode(BaseNode):
chains_dict[chain_name] = chains_dict[chain_name] | output_parser chains_dict[chain_name] = chains_dict[chain_name] | output_parser
async_runner = RunnableParallel(**chains_dict) async_runner = RunnableParallel(**chains_dict)
batch_results = await async_runner.ainvoke({"question": user_prompt}) batch_results = async_runner.invoke({"question": user_prompt})
merge_prompt = PromptTemplate( merge_prompt = PromptTemplate(
template=template_merge_prompt, template=template_merge_prompt,
@ -154,7 +154,7 @@ class GenerateAnswerNode(BaseNode):
merge_chain = merge_prompt | self.llm_model merge_chain = merge_prompt | self.llm_model
if output_parser: if output_parser:
merge_chain = merge_chain | output_parser merge_chain = merge_chain | output_parser
answer = await merge_chain.ainvoke({"context": batch_results, "question": user_prompt}) answer = merge_chain.invoke({"context": batch_results, "question": user_prompt})
state.update({self.output[0]: answer}) state.update({self.output[0]: answer})
return state return state