diff --git a/rag/svr/sync_data_source.py b/rag/svr/sync_data_source.py
index 400f90370..d6603f68f 100644
--- a/rag/svr/sync_data_source.py
+++ b/rag/svr/sync_data_source.py
@@ -714,4 +714,4 @@ async def main():
 if __name__ == "__main__":
     faulthandler.enable()
     init_root_logger(CONSUMER_NAME)
-    asyncio.run(main)
+    asyncio.run(main())