From deea07e905fa646e626e9c90495c042ae9c375d0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=B9=9B=E9=9C=B2=E5=85=88=E7=94=9F?=
 <zhanluxianshen@163.com>
Date: Tue, 2 Sep 2025 14:48:45 +0800
Subject: [PATCH] make clean() function in index_processor_base abstractmethod
 (#24959)

Signed-off-by: zhanluxianshen <zhanluxianshen@163.com>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
---
 api/core/rag/index_processor/index_processor_base.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/api/core/rag/index_processor/index_processor_base.py b/api/core/rag/index_processor/index_processor_base.py
index 2bcd1c79bb..c099fd1d5c 100644
--- a/api/core/rag/index_processor/index_processor_base.py
+++ b/api/core/rag/index_processor/index_processor_base.py
@@ -30,6 +30,7 @@ class BaseIndexProcessor(ABC):
     def load(self, dataset: Dataset, documents: list[Document], with_keywords: bool = True, **kwargs):
         raise NotImplementedError
 
+    @abstractmethod
     def clean(self, dataset: Dataset, node_ids: Optional[list[str]], with_keywords: bool = True, **kwargs):
         raise NotImplementedError