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

netx: log netx.ume.schedule/sync INFO to stderr for prod log files

Browse source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
oliver 2026-05-12 11:18:32 +08:00
parent 936cee1aa2
commit 17cd469b1a
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
netx_api/main.py
View file

@ -492,8 +492,23 @@ def sql_ume_query(payload: dict[str, Any] | None = None, db: Session = Depends(g
raise HTTPException(status_code=400, detail=f"sql_failed:{str(exc)[:240]}") from exc raise HTTPException(status_code=400, detail=f"sql_failed:{str(exc)[:240]}") from exc
def _configure_ume_diag_logging() -> None:
"""Emit netx.ume.* INFO to stderr so background scripts/.run/*.log and consoles show scheduler lines."""
fmt = logging.Formatter("%(asctime)s %(levelname)s %(name)s: %(message)s")
for name in ("netx.ume.schedule", "netx.ume.sync"):
lg = logging.getLogger(name)
if lg.handlers:
continue
h = logging.StreamHandler()
h.setFormatter(fmt)
lg.addHandler(h)
lg.setLevel(logging.INFO)
lg.propagate = False
@app.on_event("startup") @app.on_event("startup")
def on_startup() -> None: def on_startup() -> None:
_configure_ume_diag_logging()
Base.metadata.create_all(bind=engine) Base.metadata.create_all(bind=engine)
_reset_runtime_pause_flags() _reset_runtime_pause_flags()
_fail_stale_running_sync_jobs_on_startup() _fail_stale_running_sync_jobs_on_startup()