Spaces:
Sleeping
Sleeping
Commit ·
7114101
1
Parent(s): ae9c7a5
fixed source doc issue
Browse files- app/api/v1/routes.py +11 -8
- app/services/RAG_service.py +1 -0
app/api/v1/routes.py
CHANGED
|
@@ -212,16 +212,19 @@ async def query_document(
|
|
| 212 |
# Extract source documents from results
|
| 213 |
sources = []
|
| 214 |
if hasattr(session.rag_service, 'result') and session.rag_service.result:
|
| 215 |
-
matches = session.rag_service.result
|
| 216 |
for match in matches[:3]: # Top 3 sources
|
| 217 |
-
metadata = match.
|
| 218 |
-
|
| 219 |
-
|
| 220 |
-
page=metadata.get('page_no', metadata.get('page', 0)),
|
| 221 |
-
text=metadata.get('text', ''),
|
| 222 |
-
score=match.get('score', 0.0),
|
| 223 |
-
metadata=metadata
|
| 224 |
))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 225 |
|
| 226 |
return QueryResponse(
|
| 227 |
session_id=session_id,
|
|
|
|
| 212 |
# Extract source documents from results
|
| 213 |
sources = []
|
| 214 |
if hasattr(session.rag_service, 'result') and session.rag_service.result:
|
| 215 |
+
matches = session.rag_service.result
|
| 216 |
for match in matches[:3]: # Top 3 sources
|
| 217 |
+
metadata = match.metadata
|
| 218 |
+
score = session.rag_service.metadataservice.cosine_similarity(vec1=session.rag_service.embedding_model.embed_query(match.page_content), vec2=session.rag_service.embedding_model.embed_query(
|
| 219 |
+
session.rag_service.query
|
|
|
|
|
|
|
|
|
|
|
|
|
| 220 |
))
|
| 221 |
+
sources.append(SourceDocument(
|
| 222 |
+
doc_id=metadata['doc_id'],
|
| 223 |
+
page=metadata['page_no'],
|
| 224 |
+
text=match.page_content,
|
| 225 |
+
score=score,
|
| 226 |
+
metadata=metadata
|
| 227 |
+
))
|
| 228 |
|
| 229 |
return QueryResponse(
|
| 230 |
session_id=session_id,
|
app/services/RAG_service.py
CHANGED
|
@@ -91,6 +91,7 @@ class RAGService:
|
|
| 91 |
|
| 92 |
def create_query_embedding(self, query: str):
|
| 93 |
print("[RAGService] Creating query embedding...")
|
|
|
|
| 94 |
self.query_embedder = QueryEmbedding(query=query, embedding_model=self.embedding_model)
|
| 95 |
self.query_embedding = self.query_embedder.get_embedding()
|
| 96 |
print(f"[RAGService] Query embedding created: {self.query_embedding}")
|
|
|
|
| 91 |
|
| 92 |
def create_query_embedding(self, query: str):
|
| 93 |
print("[RAGService] Creating query embedding...")
|
| 94 |
+
self.query = query
|
| 95 |
self.query_embedder = QueryEmbedding(query=query, embedding_model=self.embedding_model)
|
| 96 |
self.query_embedding = self.query_embedder.get_embedding()
|
| 97 |
print(f"[RAGService] Query embedding created: {self.query_embedding}")
|