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

Refresh Fabric KPIs live while an LLDP collect job is running.

Browse source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
oliver 2026-08-04 21:56:01 +08:00
parent 2cbdc896f6
commit ba038a3af6
2 changed files with 16 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

11
netx_api/lldp_collect_service.py
View file

@ -20,6 +20,7 @@ from .topology_service import (
get_discover_job, get_discover_job,
prune_discover_jobs, prune_discover_jobs,
reclaim_stale_discover_jobs, reclaim_stale_discover_jobs,
refresh_fabric_stats,
start_discover_job, start_discover_job,
) )
@ -256,8 +257,16 @@ def start_collect(db: Session, *, trigger_mode: str = "manual") -> dict:
def get_dashboard(db: Session) -> LldpCollectDashboardOut: def get_dashboard(db: Session) -> LldpCollectDashboardOut:
policy = ensure_policy(db) policy = ensure_policy(db)
stats = db.get(TopoFabricStats, "global")
running = has_running_job(db) running = has_running_job(db)
# While a collect job is writing Fabric, refresh KPIs from live tables so the
# board tracks mid-job growth (job.edges_added already moves; cached stats did not).
# Missing marks are still applied only at job end — stale/missing may lag until then.
if running is not None:
stats = refresh_fabric_stats(db)
else:
stats = db.get(TopoFabricStats, "global")
if stats is None:
stats = refresh_fabric_stats(db)
last = last_finished_job(db) last = last_finished_job(db)
return LldpCollectDashboardOut( return LldpCollectDashboardOut(
policy=_policy_out(policy), policy=_policy_out(policy),

6
netx_api/topology_discover_jobs.py
View file

@ -111,6 +111,12 @@ def _run_discover_job(job_id: str, body: FabricDiscoverRequest) -> None:
job.edges_updated = updated job.edges_updated = updated
job.updated_at = _utcnow() job.updated_at = _utcnow()
db.commit() db.commit()
# Keep Fabric KPI cache roughly in sync during long runs (dashboard polls job).
if int(job.done or 0) % 50 == 0:
try:
refresh_fabric_stats(db)
except Exception: # noqa: BLE001
db.rollback()
# Absent on a successfully scanned endpoint → missing; purge after N cycles. # Absent on a successfully scanned endpoint → missing; purge after N cycles.
if scanned_ok: if scanned_ok: