zlei6/ragflow
1
0
Fork 0
mirror of https://github.com/infiniflow/ragflow.git synced 2026-07-06 03:18:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix harness streaming emit (#16486)

Browse Source
This commit is contained in:
Yingfeng
2026-06-30 18:06:03 +08:00
committed by GitHub
parent 3c946a7e58
commit 63bdf5c5b1
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
internal/harness/graph/pregel/stream.go
View File

@@ -276,6 +276,8 @@ func (sm *StreamManager) EmitDebug(step int, message string, data any) {
}
// EmitFinal emits final event with complete state.
// Uses blocking channel send to guarantee delivery — dropping the final event
// would cause RunSync to return nil state (silent data loss).
func (sm *StreamManager) EmitFinal(step int, state any) {
if !sm.shouldEmit(EventTypeFinal) {
return
@@ -285,8 +287,7 @@ func (sm *StreamManager) EmitFinal(step int, state any) {
event.Data = map[string]any{
"state": state,
}
sm.emit(event)
sm.eventCh <- event
}
// emit sends an event to the channel.