diff --git a/service/task_executor/task.py b/service/task_executor/task.py
index b619e0a..a46abca 100644
--- a/service/task_executor/task.py
+++ b/service/task_executor/task.py
@@ -135,7 +135,9 @@ def process_retry_tasks():
     """处理重试任务"""
     try:
         retry_tasks = database.get_failed_tasks_for_retry(
-            "文档解析", max_retry_count=MAX_PARSE_RETRY_COUNT, limit=3
+            "文档解析",
+            max_retry_count=MAX_PARSE_RETRY_COUNT,
+            limit=FAILED_RETRY_BATCH_LIMIT,
         )
         
         if retry_tasks:
@@ -226,6 +228,7 @@ EXECUTOR_RESTART_COOLDOWN_SEC = int(os.getenv("TASK_EXECUTOR_RESTART_COOLDOWN_SE
 QUEUED_TASK_STALE_SEC = int(os.getenv("TASK_QUEUED_STALE_SEC", "120"))
 RUNNING_TASK_STALE_SEC = int(os.getenv("TASK_RUNNING_STALE_SEC", "180"))
 MAX_PARSE_RETRY_COUNT = int(os.getenv("TASK_PARSE_MAX_RETRY_COUNT", "3"))
+FAILED_RETRY_BATCH_LIMIT = max(1, int(os.getenv("TASK_FAILED_RETRY_BATCH_LIMIT", "40")))
 PARSE_DOC_MAX_WORKERS = max(1, int(os.getenv("TASK_PARSE_DOC_MAX_WORKERS", "40")))
 PARSE_DOC_OCR_POOL = "ocr"
 PARSE_DOC_GENERAL_POOL = "general"