iwdZddlmZddlZddlZddlmZmZddlm Z ddl m Z eje ZdZedZed Zed Zed ZeGd d ZGddZy)u core/merge/merge_telemetry.py MergeTelemetry — observability layer for the SemanticMergeInterceptor pipeline. Tracks: - Total merge count (Redis counter: genesis:merge:stats:total) - Conflict count (Redis counter: genesis:merge:stats:conflicts) - Opus invocation (Redis counter: genesis:merge:stats:opus_calls) - Latency list (Redis list: genesis:merge:stats:latencies) - Full event log (append-only JSONL: data/observability/events.jsonl) Design notes: - Redis client is injected (optional). When None, only the in-memory latency list and events.jsonl are used. Conflict / Opus counters cannot be tracked without Redis in the no-Redis fallback mode (they stay at 0). - Division-by-zero is always guarded: rates return 0.0 when total == 0. - MergeRecord is a plain dataclass serialisable via dataclasses.asdict(). # VERIFICATION_STAMP # Story: 7.05 # Verified By: parallel-builder # Verified At: 2026-02-25 # Tests: 12/12 # Coverage: 100% ) annotationsN) dataclassasdict)Optional)Pathzgenesis:merge:statsz:totalz :conflictsz :opus_callsz :latenciescNeZdZUdZded<ded<ded<ded<d ed <ded <y ) MergeRecordz:Immutable record describing one completed merge operation.str session_idint delta_countconflict_countbool used_opusfloatmerge_latency_mssuccessN)__name__ __module__ __qualname____doc____annotations__3/mnt/e/genesis-system/core/merge/merge_telemetry.pyr r 7s&DOO Mrr c<eZdZdZ d ddZd dZd dZd dZy) MergeTelemetryaB Observability collector for merge operations. Args: redis_client: An optional redis.Redis instance (or compatible mock). When *None*, only the in-memory latency list and events.jsonl are used. events_path: Path to the append-only JSONL event log. Nc@||_t||_g|_y)N)redisr events_path _latencies)self redis_clientr s r__init__zMergeTelemetry.__init__Ss! "  ,(*rc |j|jjt|jdkDr|jjt|j r|jjt |jjtt|j|jj|j|j|tjd|j |j"|j|j |j|j$y)z Record a completed merge event. Increments Redis counters (when available) and appends the full MergeRecord to events.jsonl. Args: merge_result: A fully populated MergeRecord from the caller. NrzZMergeTelemetry.record: session=%s deltas=%d conflicts=%d opus=%s latency=%.2fms success=%s)rincr _KEY_TOTALr_KEY_CONFLICTSr_KEY_OPUS_CALLSrpush_KEY_LATENCIESr rr!append _write_eventloggerdebugr r r)r" merge_results rrecordzMergeTelemetry.recordcs :: ! JJOOJ '**Q. /%% 0 JJ  ^S1N1N-O P |<<= ,'  0  # #  $ $  ' '  " "  ) )   rc~|jt|jjtxsd}t|jjtxsd}t|jjt xsd}|jj tdd}|r|Dcgc] }t|c}ng}n.t|j}d}d}t|j}||dkDr||z dznd|dkDr||z dznd|rt|t|z dSddScc}w)u\ Return aggregated merge statistics. Returns: dict with keys: total_merges (int) conflict_rate_pct (float) — 0.0 when total is 0 opus_rate_pct (float) — 0.0 when total is 0 avg_latency_ms (float) — 0.0 when no latencies recorded rdg) total_mergesconflict_rate_pct opus_rate_pctavg_latency_ms) rr getr'r(r)lranger+rlenr!listsum)r"total conflicts opus_callsrawx latenciess r get_statszMergeTelemetry.get_statss :: ! z27a8EDJJNN>:?a@ITZZ^^O<ABJ**##NAr:C@C%<1eAh%<I(EIJT__-I">Cai)e"3c"9S;@19j5036#CLs9~I>   SV   &=s8D:c |jjjddtjt |d}|jj dd5}|j|dzd d d y #1swYy xYw#t$r+}tjd |j|Yd }~y d }~wwxYw) u Append *record* as a single JSON line to events.jsonl. Creates parent directories if they do not exist. Failures are logged as warnings — telemetry must never crash the caller. T)parentsexist_okF) ensure_asciiazutf-8)encoding Nu9MergeTelemetry._write_event: could not write to %s — %s) r parentmkdirjsondumpsropenwriteOSErrorr.warning)r"r1linefhexcs rr-zMergeTelemetry._write_events     # # ) )$ ) F::fVn5AD!!&&sW&= &% & & &  NNK     s6A$B&B;BB  B B C!B??C)Nzdata/observability/events.jsonl)r r returnNone)r0r rWrX)rWdict)r1r rWrX)rrrrr$r1rDr-rrrrrHs9< * *  * " H Hrr)r __future__rrNlogging dataclassesrrtypingrpathlibr getLoggerrr. REDIS_PREFIXr'r(r)r+r rrrrras6# )   8 $ % ~V $  >,!N+. >,   uur