fix(aider-processor): init_worker_redis_pool before XREADGROUP
All checks were successful
CD Pipeline / build-and-deploy (push) Successful in 9m35s
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:
@@ -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())
|
||||
|
||||
Reference in New Issue
Block a user