diff --git a/apps/api/src/workers/aider_event_processor.py b/apps/api/src/workers/aider_event_processor.py
index dd828f3d..d7a8ad67 100644
--- a/apps/api/src/workers/aider_event_processor.py
+++ b/apps/api/src/workers/aider_event_processor.py
@@ -20,7 +20,7 @@ from typing import Any
 
 import structlog
 
-from src.core.redis_client import get_redis, get_worker_redis
+from src.core.redis_client import get_redis, get_worker_redis, init_worker_redis_pool
 from src.db.base import get_session_factory
 from src.models.aider import AiderEventIn
 from src.repositories.aider_event_repository import AiderEventRepository
@@ -76,6 +76,7 @@ class AiderEventProcessor:
         if self._running:
             logger.warning("aider_processor_already_running")
             return
+        await init_worker_redis_pool()  # 確保 worker 專屬長連線池就緒（冪等）
         await self._ensure_consumer_group()
         self._running = True
         self._task = asyncio.create_task(self._consume_loop())