diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py
index 4144e9cbb8..f1edd45f7a 100644
--- a/rag/svr/task_executor.py
+++ b/rag/svr/task_executor.py
@@ -1289,6 +1289,7 @@ async def do_handle_task(task):
         )
 
     finally:
+        executor.shutdown(wait=False)
         if has_canceled(task_id):
             try:
                 exists = await thread_pool_exec(