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:
Cyber MacGeddon 2026-03-23 13:02:37 +00:00
parent 5c6fe90fe2
commit a3ea1382a2
8 changed files with 0 additions and 18 deletions

View file

@ -218,10 +218,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 _librarian_request(self, request, timeout=120):
"""Send a request to the librarian and wait for response."""