monoadmin/the-other-dude
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(03-01): wire config snapshot subscriber into main.py lifespan

Browse Source 
- Start config_snapshot_subscriber in lifespan startup (non-fatal)
- Stop config_snapshot_subscriber in lifespan shutdown
- Placed after push_rollback_subscriber (near config-related subscribers)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
Jason Staack
2026-03-12 21:47:51 -05:00
parent 3ab9f27d49
commit 0db06419e7
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
backend/app/main.py
View File

@@ -214,6 +214,17 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
except Exception as e: except Exception as e:
logger.error("Push rollback subscriber failed to start (non-fatal): %s", e) logger.error("Push rollback subscriber failed to start (non-fatal): %s", e)
# Config snapshot ingestion subscriber (Go poller -> PostgreSQL via Transit encryption)
config_snapshot_nc = None
try:
from app.services.config_snapshot_subscriber import (
start_config_snapshot_subscriber,
stop_config_snapshot_subscriber,
)
config_snapshot_nc = await start_config_snapshot_subscriber()
except Exception as e:
logger.error("Config snapshot subscriber failed to start (non-fatal): %s", e)
logger.info("startup complete, ready to serve requests") logger.info("startup complete, ready to serve requests")
yield yield
@@ -228,6 +239,8 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
await stop_config_change_subscriber() await stop_config_change_subscriber()
if push_rollback_nc: if push_rollback_nc:
await stop_push_rollback_subscriber() await stop_push_rollback_subscriber()
if config_snapshot_nc:
await stop_config_snapshot_subscriber()
# Dispose database engine connections to release all pooled connections cleanly. # Dispose database engine connections to release all pooled connections cleanly.
from app.database import app_engine, engine from app.database import app_engine, engine