dasomaru commited on
Commit
7d54334
ยท
verified ยท
1 Parent(s): a88d56c

Update services/rag_pipeline.py

Browse files
Files changed (1) hide show
  1. services/rag_pipeline.py +24 -21
services/rag_pipeline.py CHANGED
@@ -1,21 +1,24 @@
1
- # from retriever.vectordb import search_documents
2
- from retriever.vectordb_rerank import search_documents
3
- from generator.prompt_builder import build_prompt
4
- from generator.llm_inference import generate_answer
5
-
6
- def rag_pipeline(query: str, top_k: int = 5) -> str:
7
- """
8
- 1. ์‚ฌ์šฉ์ž ์งˆ๋ฌธ์œผ๋กœ ๊ด€๋ จ ๋ฌธ์„œ๋ฅผ ๊ฒ€์ƒ‰
9
- 2. ๊ฒ€์ƒ‰๋œ ๋ฌธ์„œ์™€ ํ•จ๊ป˜ ํ”„๋กฌํ”„ํŠธ ๊ตฌ์„ฑ
10
- 3. ํ”„๋กฌํ”„ํŠธ๋กœ๋ถ€ํ„ฐ ๋‹ต๋ณ€ ์ƒ์„ฑ
11
- """
12
- # 1. ๊ฒ€์ƒ‰
13
- context_docs = search_documents(query, top_k=top_k)
14
-
15
- # 2. ํ”„๋กฌํ”„ํŠธ ์กฐ๋ฆฝ
16
- prompt = build_prompt(query, context_docs)
17
-
18
- # 3. ๋ชจ๋ธ ์ถ”๋ก 
19
- output = generate_answer(prompt)
20
-
21
- return output
 
 
 
 
1
+ # from retriever.vectordb import search_documents
2
+ from retriever.vectordb_rerank import search_documents
3
+ from generator.prompt_builder import build_prompt
4
+ from generator.llm_inference import generate_answer
5
+
6
+ def rag_pipeline(query: str, top_k: int = 5) -> str:
7
+ """
8
+ 1. ์‚ฌ์šฉ์ž ์งˆ๋ฌธ์œผ๋กœ ๊ด€๋ จ ๋ฌธ์„œ๋ฅผ ๊ฒ€์ƒ‰
9
+ 2. ๊ฒ€์ƒ‰๋œ ๋ฌธ์„œ์™€ ํ•จ๊ป˜ ํ”„๋กฌํ”„ํŠธ ๊ตฌ์„ฑ
10
+ 3. ํ”„๋กฌํ”„ํŠธ๋กœ๋ถ€ํ„ฐ ๋‹ต๋ณ€ ์ƒ์„ฑ
11
+ """
12
+ # 1. ๊ฒ€์ƒ‰
13
+ context_docs = search_documents(query, top_k=top_k)
14
+ print("context_docs", context_docs)
15
+
16
+ # 2. ํ”„๋กฌํ”„ํŠธ ์กฐ๋ฆฝ
17
+ prompt = build_prompt(query, context_docs)
18
+ print("prompt", prompt)
19
+
20
+ # 3. ๋ชจ๋ธ ์ถ”๋ก 
21
+ output = generate_answer(prompt)
22
+ print("output", output)
23
+
24
+ return output