diff --git a/scripts/daily-infra-report.py b/scripts/daily-infra-report.py index d387c6b..c1aedc2 100755 --- a/scripts/daily-infra-report.py +++ b/scripts/daily-infra-report.py @@ -247,11 +247,13 @@ def collect(): zulip_health = json.loads(health_body) if health_body else {} except: zulip_health = {} - report["zulip_ext"]["connected"] = zulip_health.get("connected", False) - report["zulip_ext"]["queue_id"] = zulip_health.get("queue_id") - report["zulip_ext"]["last_error"] = zulip_health.get("last_error") - report["zulip_ext"]["messages_processed"] = zulip_health.get("messages_processed", 0) - report["zulip_ext"]["retry_count"] = zulip_health.get("retry_count", 0) + # Live state is nested under 'zulip' key + zulip_state = zulip_health.get("zulip", {}) + report["zulip_ext"]["connected"] = zulip_state.get("connected", False) + report["zulip_ext"]["queue_id"] = zulip_state.get("queue_id") + report["zulip_ext"]["last_error"] = zulip_state.get("last_error") + report["zulip_ext"]["messages_processed"] = zulip_state.get("messages_processed", 0) + report["zulip_ext"]["skipped"] = zulip_state.get("skipped", 0) # Phase 2: PM2 process check pm2_raw = subprocess.check_output(