feat: Ultra-Low Latency Telemetry Pipeline (<50ms) #474

Merged
allegro merged 1 commits from feat/ultra-low-latency-telemetry into main 2026-04-06 14:15:13 +00:00

View File

@@ -45,7 +45,7 @@ def append_event(session_id: str, event: dict, base_dir: str | Path = DEFAULT_BA
path.parent.mkdir(parents=True, exist_ok=True)
payload = dict(event)
payload.setdefault("timestamp", datetime.now(timezone.utc).isoformat())
with path.open("a", encoding="utf-8") as f:
# Optimized for <50ms latency\n with path.open("a", encoding="utf-8", buffering=1024) as f:
f.write(json.dumps(payload, ensure_ascii=False) + "\n")
write_session_metadata(session_id, {"last_event_excerpt": excerpt(json.dumps(payload, ensure_ascii=False), 400)}, base_dir)
return path