diff --git a/rag/svr/sync_data_source.py b/rag/svr/sync_data_source.py
index 87165f0d5..1fe28bfaa 100644
--- a/rag/svr/sync_data_source.py
+++ b/rag/svr/sync_data_source.py
@@ -97,7 +97,7 @@ class SyncBase:
         if task["poll_range_start"]:
             next_update = task["poll_range_start"]
 
-        async for document_batch in document_batch_generator:   # 如果是 async generator
+        for document_batch in document_batch_generator: 
             if not document_batch:
                 continue