fix(aider-processor): init_worker_redis_pool before XREADGROUP
All checks were successful
CD Pipeline / build-and-deploy (push) Successful in 9m35s

Worker pool 在 main.py lifespan 未初始化(signal_worker 同問題)。
在 AiderEventProcessor.start() 冪等呼叫 init_worker_redis_pool(),
確保 _consume_loop() 的 get_worker_redis() 不拋 RuntimeError。

2026-04-20 @ Asia/Taipei
This commit is contained in:
Your Name
2026-04-20 20:21:15 +08:00
parent de2d34d4cd
commit 9a44516bf8

View File

@@ -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())