coop/rose-ash
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Skip event processor in standalone mode (no DB for LISTEN/NOTIFY)
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 2m28s
Details

Browse Source 
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
giles
2026-03-05 17:02:05 +00:00
parent 9cde15c3ce
commit c43f774992
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
shared/infrastructure/factory.py
View File

@@ -366,7 +366,7 @@ def create_base_app(
return await base_context() return await base_context()
# --- event processor --- # --- event processor ---
_event_processor = EventProcessor(app_name=name) _event_processor = None if no_db else EventProcessor(app_name=name)
# --- startup --- # --- startup ---
@app.before_serving @app.before_serving
@@ -375,11 +375,13 @@ def create_base_app(
register_shared_handlers() register_shared_handlers()
await init_config() await init_config()
print(pretty()) print(pretty())
await _event_processor.start() if _event_processor:
await _event_processor.start()
@app.after_serving @app.after_serving
async def _stop_event_processor(): async def _stop_event_processor():
await _event_processor.stop() if _event_processor:
await _event_processor.stop()
from shared.infrastructure.auth_redis import close_auth_redis from shared.infrastructure.auth_redis import close_auth_redis
await close_auth_redis() await close_auth_redis()