hansjone/netx
1
0
Fork 0
mirror of https://github.com/hansjone/netx.git synced 2026-10-09 03:10:46 +08:00
Code Issues Projects Releases 1 Packages Wiki Activity Actions 2

fix(startup): defer UME alarm sync so /health is ready quickly

Browse source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
oliver 2026-06-04 21:28:57 +08:00
parent d05b64b4c1
commit f562f50953
2 changed files with 20 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

18
netx_api/main.py
View file

@ -815,9 +815,23 @@ def on_startup() -> None:
last_error=f"startup_thread_init_failed: {str(exc)[:180]}",
)
try:
_run_startup_alarm_sync_before_ws()
def _startup_alarm_sync_worker() -> None:
try:
_run_startup_alarm_sync_before_ws()
except Exception as exc:
_schedule_log.exception("startup: alarm sync before WSS failed: %s", exc)
complete_startup_alarm_sync_gate()
# Do not block HTTP /health on slow UME REST pull; WSS waits on startup_alarm_sync_gate.
t_startup_sync = threading.Thread(
target=_startup_alarm_sync_worker,
name="ume-startup-alarm-sync",
daemon=True,
)
t_startup_sync.start()
except Exception as exc:
_schedule_log.exception("startup: alarm sync before WSS failed: %s", exc)
_schedule_log.exception("startup: alarm sync thread init failed: %s", exc)
complete_startup_alarm_sync_gate()
try:
if bool(getattr(settings, "ume_sync_alarms_current_enabled", True)):