From 68e5c86e9c13ec06622c5221526c9132c786f929 Mon Sep 17 00:00:00 2001
From: Yongteng Lei <yongtengrey@outlook.com>
Date: Tue, 13 Jan 2026 12:54:13 +0800
Subject: [PATCH] Fix: image not displaying thumbnails when using pipeline
 (#12574)

### What problem does this PR solve?

Fix image not displaying thumbnails when using pipeline.

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
---
 rag/flow/parser/parser.py | 11 ++++++++---
 rag/svr/task_executor.py  |  5 +++++
 2 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/rag/flow/parser/parser.py b/rag/flow/parser/parser.py
index b681e5d5d..a88443b7e 100644
--- a/rag/flow/parser/parser.py
+++ b/rag/flow/parser/parser.py
@@ -61,7 +61,7 @@ class ParserParam(ProcessParamBase):
                 "json",
             ],
             "image": [
-                "text",
+                "json",
             ],
             "email": [
                 "text",
@@ -120,7 +120,7 @@ class ParserParam(ProcessParamBase):
                 "lang": "Chinese",
                 "system_prompt": "",
                 "suffix": ["jpg", "jpeg", "png", "gif"],
-                "output_format": "text",
+                "output_format": "json",
             },
             "email": {
                 "suffix": [
@@ -642,7 +642,12 @@ class Parser(ProcessBase):
             else:
                 txt = cv_model.describe(img_binary.read())
 
-        self.set_output("text", txt)
+        json_result = [{
+            "text": txt,
+            "image": img,
+            "doc_type_kwd": "image",
+        }]
+        self.set_output("json", json_result)
 
     def _audio(self, name, blob):
         import os
diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py
index 7e2352a9b..622da3834 100644
--- a/rag/svr/task_executor.py
+++ b/rag/svr/task_executor.py
@@ -300,6 +300,11 @@ async def build_chunks(task, progress_callback):
                 (chunk["content_with_weight"] + str(d["doc_id"])).encode("utf-8", "surrogatepass")).hexdigest()
             d["create_time"] = str(datetime.now()).replace("T", " ")[:19]
             d["create_timestamp_flt"] = datetime.now().timestamp()
+
+            if d.get("img_id"):
+                docs.append(d)
+                return
+
             if not d.get("image"):
                 _ = d.pop("image", None)
                 d["img_id"] = ""