diff --git a/backend/app/task/tasks/db_log/tasks.py b/backend/app/task/tasks/db_log/tasks.py
index 8c0fb3e8f..da2ac66f5 100644
--- a/backend/app/task/tasks/db_log/tasks.py
+++ b/backend/app/task/tasks/db_log/tasks.py
@@ -2,17 +2,20 @@
 
 from backend.app.admin.service.login_log_service import login_log_service
 from backend.app.admin.service.opera_log_service import opera_log_service
+from backend.database.db import async_db_session
 
 
 @shared_task
 async def delete_db_opera_log() -> str:
     """自动删除数据库操作日志"""
-    await opera_log_service.delete_all()
-    return 'Success'
+    async with async_db_session.begin() as db:
+        await opera_log_service.delete_all(db=db)
+        return 'Success'
 
 
 @shared_task
 async def delete_db_login_log() -> str:
     """自动删除数据库登录日志"""
-    await login_log_service.delete_all()
-    return 'Success'
+    async with async_db_session.begin() as db:
+        await login_log_service.delete_all(db=db)
+        return 'Success'