Fix non-streaming failure in RAG services

This commit is contained in:
Cyber MacGeddon 2026-01-12 17:41:54 +00:00
parent 30ca1d2e8b
commit aacc96064f
2 changed files with 2 additions and 0 deletions

View file

@ -128,6 +128,7 @@ class Processor(FlowProcessor):
await flow("response").send(
DocumentRagResponse(
response = response,
end_of_stream = True,
error = None
),
properties = {"id": id}

View file

@ -171,6 +171,7 @@ class Processor(FlowProcessor):
await flow("response").send(
GraphRagResponse(
response = response,
end_of_stream = True,
error = None
),
properties = {"id": id}