mirror of
https://github.com/VinciGit00/Scrapegraph-ai.git
synced 2026-07-06 21:11:37 +08:00
feat: removed rag node
This commit is contained in:
parent
6d1d91a1e9
commit
930f673747
@ -1,3 +1,4 @@
|
||||
|
||||
"""
|
||||
PDFScraperGraph Module
|
||||
"""
|
||||
@ -9,7 +10,6 @@ from .abstract_graph import AbstractGraph
|
||||
|
||||
from ..nodes import (
|
||||
FetchNode,
|
||||
RAGNode,
|
||||
GenerateAnswerPDFNode
|
||||
)
|
||||
|
||||
@ -63,14 +63,7 @@ class PDFScraperGraph(AbstractGraph):
|
||||
input='pdf | pdf_dir',
|
||||
output=["doc"],
|
||||
)
|
||||
rag_node = RAGNode(
|
||||
input="user_prompt & doc",
|
||||
output=["relevant_chunks"],
|
||||
node_config={
|
||||
"llm_model": self.llm_model,
|
||||
"embedder_model": self.embedder_model
|
||||
}
|
||||
)
|
||||
|
||||
generate_answer_node_pdf = GenerateAnswerPDFNode(
|
||||
input="user_prompt & (relevant_chunks | doc)",
|
||||
output=["answer"],
|
||||
@ -83,12 +76,10 @@ class PDFScraperGraph(AbstractGraph):
|
||||
return BaseGraph(
|
||||
nodes=[
|
||||
fetch_node,
|
||||
rag_node,
|
||||
generate_answer_node_pdf,
|
||||
],
|
||||
edges=[
|
||||
(fetch_node, rag_node),
|
||||
(rag_node, generate_answer_node_pdf)
|
||||
(fetch_node, generate_answer_node_pdf)
|
||||
],
|
||||
entry_point=fetch_node
|
||||
)
|
||||
@ -104,4 +95,4 @@ class PDFScraperGraph(AbstractGraph):
|
||||
inputs = {"user_prompt": self.prompt, self.input_key: self.source}
|
||||
self.final_state, self.execution_info = self.graph.execute(inputs)
|
||||
|
||||
return self.final_state.get("answer", "No answer found.")
|
||||
return self.final_state.get("answer", "No answer found.")
|
||||
@ -117,4 +117,4 @@ class SmartScraperGraph(AbstractGraph):
|
||||
inputs = {"user_prompt": self.prompt, self.input_key: self.source}
|
||||
self.final_state, self.execution_info = self.graph.execute(inputs)
|
||||
|
||||
return self.final_state.get("answer", "No answer found.")
|
||||
return self.final_state.get("answer", "No answer found.")
|
||||
|
||||
@ -95,9 +95,7 @@ class GenerateAnswerPDFNode(BaseNode):
|
||||
output_parser = JsonOutputParser()
|
||||
format_instructions = output_parser.get_format_instructions()
|
||||
|
||||
|
||||
chains_dict = {}
|
||||
|
||||
# Use tqdm to add progress bar
|
||||
for i, chunk in enumerate(
|
||||
tqdm(doc, desc="Processing chunks", disable=not self.verbose)
|
||||
@ -107,7 +105,7 @@ class GenerateAnswerPDFNode(BaseNode):
|
||||
template=template_no_chunks_pdf,
|
||||
input_variables=["question"],
|
||||
partial_variables={
|
||||
"context": chunk.page_content,
|
||||
"context":chunk,
|
||||
"format_instructions": format_instructions,
|
||||
},
|
||||
)
|
||||
@ -116,7 +114,7 @@ class GenerateAnswerPDFNode(BaseNode):
|
||||
template=template_chunks_pdf,
|
||||
input_variables=["question"],
|
||||
partial_variables={
|
||||
"context": chunk.page_content,
|
||||
"context":chunk,
|
||||
"chunk_id": i + 1,
|
||||
"format_instructions": format_instructions,
|
||||
},
|
||||
|
||||
Loading…
Reference in New Issue
Block a user