apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-04-25 00:16:23 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Fix stray log messages caused by librarian messages (#706)

Browse source 
Warning generated by librarian responses meant for other
services (chunker, embeddings, etc.) arriving on the shared
response queue. The decoder's subscription picks them up, can't
match them to a pending request, and logs a warning.

Removed the warnings, as not serving a purpose.
This commit is contained in:
cybermaggedon 2026-03-23 13:16:39 +00:00 • committed by GitHub
parent 5c6fe90fe2
commit 25995d03f4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
8 changed files with 0 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/agent/react/service.py
View file

@ -189,8 +189,6 @@ class Processor(AgentService):
if request_id in self.pending_librarian_requests:
future = self.pending_librarian_requests.pop(request_id)
future.set_result(response)
else:
logger.warning(f"Received unexpected librarian response: {request_id}")
async def save_answer_content(self, doc_id, user, content, title=None, timeout=120):
"""

2
trustgraph-flow/trustgraph/decoding/mistral_ocr/processor.py
View file

@ -162,8 +162,6 @@ class Processor(FlowProcessor):
if request_id and request_id in self.pending_requests:
future = self.pending_requests.pop(request_id)
future.set_result(response)
else:
logger.warning(f"Received unexpected librarian response: {request_id}")
async def fetch_document_metadata(self, document_id, user, timeout=120):
"""

2
trustgraph-flow/trustgraph/decoding/pdf/pdf_decoder.py
View file

@ -126,8 +126,6 @@ class Processor(FlowProcessor):
if request_id and request_id in self.pending_requests:
future = self.pending_requests.pop(request_id)
future.set_result(response)
else:
logger.warning(f"Received unexpected librarian response: {request_id}")
async def fetch_document_metadata(self, document_id, user, timeout=120):
"""

2
trustgraph-flow/trustgraph/retrieval/document_rag/rag.py
View file

@ -139,8 +139,6 @@ class Processor(FlowProcessor):
if request_id in self.pending_requests:
future = self.pending_requests.pop(request_id)
future.set_result(response)
else:
logger.warning(f"Received unexpected librarian response: {request_id}")
async def fetch_chunk_content(self, chunk_id, user, timeout=120):
"""Fetch chunk content from librarian/Garage."""

2
trustgraph-flow/trustgraph/retrieval/graph_rag/rag.py
View file

@ -169,8 +169,6 @@ class Processor(FlowProcessor):
if request_id and request_id in self.pending_librarian_requests:
future = self.pending_librarian_requests.pop(request_id)
future.set_result(response)
else:
logger.warning(f"Received unexpected librarian response: {request_id}")
async def save_answer_content(self, doc_id, user, content, title=None, timeout=120):
"""