From d1e172171f5c13e3fc58a3d67b63430582114b9a Mon Sep 17 00:00:00 2001
From: Stephen Hu <812791840@qq.com>
Date: Mon, 1 Dec 2025 17:46:44 +0800
Subject: [PATCH] Refactor: better describe how to get prefix for sync data
 source  (#11636)

### What problem does this PR solve?

better describe how to get prefix for sync data source

### Type of change

- [x] Refactoring
---
 rag/svr/sync_data_source.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/rag/svr/sync_data_source.py b/rag/svr/sync_data_source.py
index a5c4c4cfb..fbe3722d5 100644
--- a/rag/svr/sync_data_source.py
+++ b/rag/svr/sync_data_source.py
@@ -112,7 +112,7 @@ class SyncBase:
                             failed_docs += len(docs)
                             continue
 
-                    prefix = "[Jira] " if self.SOURCE_NAME == FileSource.JIRA else ""
+                    prefix = self._get_source_prefix()
                     if failed_docs > 0:
                         logging.info(f"{prefix}{doc_num} docs synchronized till {next_update} ({failed_docs} skipped)")
                     else:
@@ -128,6 +128,9 @@ class SyncBase:
 
     async def _generate(self, task: dict):
         raise NotImplementedError
+    
+    def _get_source_prefix(self):
+        return ""
 
 
 class S3(SyncBase):
@@ -402,6 +405,9 @@ class GoogleDrive(SyncBase):
 class Jira(SyncBase):
     SOURCE_NAME: str = FileSource.JIRA
 
+    def _get_source_prefix(self):
+        return "[Jira]"
+
     async def _generate(self, task: dict):
         connector_kwargs = {
             "jira_base_url": self.conf["base_url"],