update(infrastructure-update): v1.3.0 — full 5-host Docker ecosystem coverage (live-verified 2026-09-08) #64
@@ -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(
|
||||
|
||||
Reference in New Issue
Block a user