File tree Expand file tree Collapse file tree 1 file changed +14
-3
lines changed Expand file tree Collapse file tree 1 file changed +14
-3
lines changed Original file line number Diff line number Diff line change 10
10
11
11
from ..nodes import (
12
12
FetchNode ,
13
+ RAGNode ,
13
14
GenerateAnswerPDFNode
14
15
)
15
16
@@ -63,7 +64,15 @@ def _create_graph(self) -> BaseGraph:
63
64
input = 'pdf | pdf_dir' ,
64
65
output = ["doc" ],
65
66
)
66
-
67
+
68
+ rag_node = RAGNode (
69
+ input = "user_prompt & (parsed_doc | doc)" ,
70
+ output = ["relevant_chunks" ],
71
+ node_config = {
72
+ "llm_model" : self .llm_model ,
73
+ "embedder_model" : self .embedder_model
74
+ }
75
+ )
67
76
generate_answer_node_pdf = GenerateAnswerPDFNode (
68
77
input = "user_prompt & (relevant_chunks | doc)" ,
69
78
output = ["answer" ],
@@ -76,10 +85,12 @@ def _create_graph(self) -> BaseGraph:
76
85
return BaseGraph (
77
86
nodes = [
78
87
fetch_node ,
88
+ rag_node ,
79
89
generate_answer_node_pdf ,
80
90
],
81
91
edges = [
82
- (fetch_node , generate_answer_node_pdf )
92
+ (fetch_node , rag_node ),
93
+ (rag_node , generate_answer_node_pdf )
83
94
],
84
95
entry_point = fetch_node
85
96
)
@@ -95,4 +106,4 @@ def run(self) -> str:
95
106
inputs = {"user_prompt" : self .prompt , self .input_key : self .source }
96
107
self .final_state , self .execution_info = self .graph .execute (inputs )
97
108
98
- return self .final_state .get ("answer" , "No answer found." )
109
+ return self .final_state .get ("answer" , "No answer found." )
You can’t perform that action at this time.
0 commit comments