+ iHj+ *Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t ]P!R4t ]!RR04tRR ltR R ltR R RR/RRlltRRltR#tRRRRRR RRRR/RRlltR$RRlltRRRRRR/RR lltR!R"ltR#)%aBContent-free per-attempt compression telemetry (attempt log line, Relay mark, shared metric). Sibling of ``agent/conversation_compression.py`` (the facade), which imports it at module level; this module must never import the facade (import cycle). It logs under the facade's logger name so log consumers keep one source. ) annotationsN)Any)publish_attemptzagent.conversation_compression no_progresssummary_generation_abortedc$V^8dQhRRRRRR/#)messageslist verbatim_tail list | Nonereturn)formats"M/home/ubuntu/.hermes/hermes-agent/agent/conversation_compression_telemetry.py __annotate__r s"   k Va cV'gV#^RIHpV!V\P!V44# \d\ P RRR7R#i;i)zZContent-only snapshot for final effect accounting; telemetry must never break compression.rejoin_compressed_head_and_tailz+failed to snapshot compression effect inputTexc_infoN)hermes_cli.partial_compressrcopydeepcopy Exceptionloggerdebug)r r rs&& r"_snapshot_compression_effect_inputr sKOO.x}9UVV  BT Rs//"/"AAc 0V^8dQhRRRRRRRRRR R R /#) ragentrmessages_beforer messages_afterr r split_statusstrr Noner)rs"rrr-sDUU U!,U>BUS^UnqU UrcVfR#V'dVR8Xd^RIHpV!W#4p\VPRR4p\ V4'd V!W4R#R# \ d\ PRRR7R#i;i)zRFinalize effect fields from the transcript shape that crossed the commit boundary.Nnot_applicabler$_record_committed_compression_effectz-failed to record committed compression effectTr)rrgetattrcontext_compressorcallablerrr)r r!r"r r#rrecorders&&&&& r _record_committed_attempt_effectr--s} U \-== S=^[N5335[]ab H   _ 5  U Dt TUsAAA"A?>A? attempt_beganT attempt_seedc(V^8dQhRRRRRRRR/#) rr rr.boolr/dict[str, Any] | Noner dict[str, Any]r)rs"rrr@s, "&=RrcV'd \V4#V'd\VRR4MRpRT;'g \P!4PR\VRR4;'gRRR/#)arThis attempt's id, the session it started in, and its trigger. ``attempt_seed`` is the attempt's own copy and wins: the agent's current-attempt fields belong to the newest attempt, so a stalled attempt unwinding after its fallback began would otherwise log the fallback's identity. An emit with no attempt begun (pool saturation) gets a fresh id and an unknown trigger._compression_attempt_idN attempt_id session_idtrigger_sourceunknown)dictr)uuiduuid4hex)r r.r/r6s&$$ r _attempt_seedr?@sfL!!DQ 94@W[Jj44DJJL$4$4lGES_acDdDjDjhj) rc V^8dQhRRRR/#)rpayloadr3r r%r)rs"rrrQsyyyDyrc `\PR\P!VRRR74R#)zTThe one attempt log line; ``scripts/micro_compaction_report.py`` parses this prefix.z)context compression attempt telemetry: %sT) sort_keys separatorsN),:)rinfojsondumps)rAs&r_log_attempt_recordrJQs  KK;TZZ[_lv=wxr failure_classcommit_started_atinclude_last_telemetryhistory_rewrittenc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #)rr r started_atfloat commit_statusr$r#rK str | NonerLz float | NonerMr1r/r2rNz bool | Noner r%r)rs"rrrZsp<]<] <]$<]58<]HK<]\f<]#<]DH<](<]DO<] <]rc jVPp V'd\V RR4MRp \WVR7p \V \4;'dV P R4V R,8Hp V 'g /V CRR/Cp \ V 4p V P RR4V P R R 4V P RV R,4V P R V R ,4V P\\P!4V, R ,4VVR 7VeWR&VR8wd(V'g \FpV PVR4K Ve?\^\\P!4V, R ,44;V R&V R&V'd/V\9d V 'dV P R4'gWMR&V P RR4V P R^4\V P R4;'g-T ;'d#\V RR4;'g\V RR44V R&\!V 4\#W 4^RIHpV!W-P R4\VPRR4VR7R# \(d$p\*P-RTRR7Rp?R#Rp?ii;i)aEmit one content-free JSON log line for a compression attempt. ``include_last_telemetry=False`` is for emits that fire without an attempt having begun (pool-saturation refusals): they must not hydrate from the previous attempt's numbers. ``attempt_seed`` is the emitting attempt's own seed (see ``_attempt_seed``). ``history_rewritten`` (commit path only) says whether the returned transcript replaced the input, which a split that failed after publishing the compacted history still did._last_compression_telemetryN)r.r/r6methodnoneeventcompression_attemptroutehermesr7)total_duration_msrRr#rN committed commit_msrKchunkingF chunk_count fallback_used_last_summary_fallback_used_last_aux_model_failure_model)finish_compression_attemptcontext_length)r 0failed to emit compression attempt telemetry: %sTr)r*r)r? isinstancer;get setdefaultupdateinttime monotonic_CANDIDATE_EFFECT_FIELDSpopmax_GENERIC_ABORT_VERDICTSr1rJr.hermes_cli.observability.shared_metrics_eventsrerrr)r rPrRr#rKrLrMr/rN compressor telemetryseedownrAkeyreexcs&$$$$$$$$ r#_emit_compression_attempt_telemetryrzZsl0]-- PfGJ(EtLlp UWcdD)__immL.ITR^M_._34262Iy/7$9:7H-<l);<<l);<!4>>#3j#@D"HIYf%    (+<' ( K '0A/ C&0  (AJ J J"A J J2J--J2c ,V^8dQhRRRRRRRRR R /#) rr rrPrQrKrSr/r2r r%r)rs"rrrs4 !2<La rc &\WRRVVR7R#)aborted)rPrRr#rKr/N)rz)r rPrKr/s&&&&r_emit_aborted_attempt_telemetryr~s( IIer!rrZr[rVrWc<V^8dQhRRRRRRRRR RR RR RR R RR/ #)rr rrPrQrRr$rKrS approx_tokensrZrVr/r2r r%r)rs"rrrsa"Y"Y "Y!"Y58"YIS"Ydg"Y "Y#&"Y?T"Y "Yrc\VRR4pRRRVRVRV/\WR7CR \VR R 4;'gR R \VR R 4;'gR R\VRR4R\VRR4R\V\4'dTMRR\\P !4V, R,4RVRRRR/ Cp \ V 4\W 4^RI H p V !4R# \d#p \PRT RR7Rp ? L8Rp ? ii;i \d\PRRR7R#i;i ^RI H p T !4i \d\PRRR7ii;i;i)aYLog one attempt that never reached the local compressor: an automatic gate blocked it, Codex owns the thread, or the session lease showed another path already owns the work. The compressor's telemetry still describes an earlier attempt, so this record starts from the attempt seed. Shared metrics have never counted these exits and still do not.r*NrXrYrZrVrK)r/ main_providerproviderr8 main_modelmodelmain_context_limit_resolved_context_lengtheffective_threshold_threshold_tokenscurrent_estimated_tokensr]r\rRr#r'rbFrgTr)discard_compression_attemptz-failed to discard bypassed compression metric) r)r?rhrlrmrnrJrrrrrsr) r rPrRrKrrZrVr/rtrAryrs &&$$$$$$ r _emit_bypassed_attempt_telemetryrsuYU$8$? *GUHfo_l  E=   WUJ;AArrs#  3   ; <$]4P$QR U&)-UY"y c<]im<]&*<]KO<]+/<]RV<]~"Y"Y)/"YW["YJ r