diff --git a/api/core/rag/entities/event.py b/api/core/rag/entities/event.py
index 8e644fcf85..4921c94557 100644
--- a/api/core/rag/entities/event.py
+++ b/api/core/rag/entities/event.py
@@ -9,8 +9,8 @@ class DatasourceStreamEvent(Enum):
     """
     Datasource Stream event
     """
-    PROCESSING = "processing"
-    COMPLETED = "completed"
+    PROCESSING = "datasource_processing"
+    COMPLETED = "datasource_completed"
 
 
 class BaseDatasourceEvent(BaseModel):