zlei6/ragflow
1
0
Fork 0
mirror of https://github.com/infiniflow/ragflow.git synced 2026-08-28 11:16:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Go: fix error handle (#18573)

Browse Source 
As title

Signed-off-by: Jin Hai <haijin.chn@gmail.com>
This commit is contained in:
Jin Hai
2026-08-20 20:13:39 +08:00
committed by GitHub
parent 295dc12cc5
commit fd74a98510
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/admin/handler.go
View File

@@ -951,6 +951,10 @@ func (h *Handler) PullMessageFromQueue(c *gin.Context) {
return
}
messages, err := msgQueueEngine.GetMessages(req.MessageCount)
if err != nil {
common.ErrorWithCode(c, common.CodeBadRequest, err.Error())
return
}
var result []map[string]string
if req.AckPolicy == "ACK" {
for _, message := range messages {

2
internal/service/memory_message_service.go
View File

@@ -377,7 +377,7 @@ func queueMemoryTask(ctx context.Context, memoryID, tenantID string, rawMessageI
if err != nil {
return fmt.Errorf("marshal memory task message: %w", err)
}
if err := mq.PublishTask(common.TaskSubject, tmPayload); err != nil {
if err = mq.PublishTask(common.TaskSubject, tmPayload); err != nil {
return fmt.Errorf("publish memory task %s: %w", taskID, err)
}
return nil