diff --git a/apps/knowledge/vector/base_vector.py b/apps/knowledge/vector/base_vector.py
index 92f250038..2a7731fce 100644
--- a/apps/knowledge/vector/base_vector.py
+++ b/apps/knowledge/vector/base_vector.py
@@ -21,7 +21,7 @@ lock = threading.Lock()
 
 
 def chunk_data(data: Dict):
-    if str(data.get('source_type')) == SourceType.PARAGRAPH.value:
+    if str(data.get('source_type')) == str(SourceType.PARAGRAPH.value):
         text = data.get('text')
         chunk_list = text_to_chunk(text)
         return [{**data, 'text': chunk} for chunk in chunk_list]