+ iHjt<Rt^RIHt^RIt^RIt^RIHt^RIHt^RI H t H t H t ^RI Ht^xtRt!RR ]]4t]!]P(]P*]P,04tR R ltR R ltRRltRRltRRltRRRRRR/RRllt!RR4tR#)a1Shared session activity observation contract: timestamp + bounded description/provenance, observation only (notification, timeout, kill and retry policy live elsewhere). Provenance is a small closed enum of *noun* sources; the default agent clock stamps ``unknown`` unless a writer passes ``provenance=``.) annotationsN)suppress)Enum)AnyMappingOptional)tgN@c.]tRt^tRtRtRtRtRtRt Rt R#) ActivityProvenancez3Where a durable/in-memory activity stamp came from.unknownzagent.compressionzagent.compression_timeoutzagent.compression_cooldownzagent.compression_turnholdN) __name__ __module__ __qualname____firstlineno____doc__UNKNOWNAGENT_COMPRESSIONAGENT_COMPRESSION_TIMEOUTAGENT_COMPRESSION_COOLDOWNAGENT_COMPRESSION_TURNHOLD__static_attributes__r ;/home/ubuntu/.hermes/hermes-agent/agent/session_activity.pyr r s$=G, ;!=!=rr c V^8dQhRRRR/#) provenance"Optional[ActivityProvenance | str]returnboolr )formats"r __annotate__r!7s YY3UYZ^Yrc&\V4\9#)zUTrue when this stamp ends a compression phase and must bypass the persist rate limit.)normalize_activity_provenance TERMINAL_COMPRESSION_PROVENANCESrs&r"is_terminal_compression_provenancer&7s ( 48X XXrc V^8dQhRRRR/#)r description Optional[str]rstrr )r s"rr!r!<skkMkckrcT;'gRP4p\V4\8:dV#VR\^, R,#)z?Clamp free-form activity text to the shared description budget.Nu…)striplenACTIVITY_DESCRIPTION_MAX)r(texts& rbound_activity_descriptionr1<sD   2 $ $ &Dt9 884jdCaE]`aEa>bej>jjrc V^8dQhRRRR/#)rrrrr r )r s"rr!r!Bs**.P*Ug*rc\V\4'dV#\T;'gRP44# \d\Pu#i;i)zBReturn a known provenance, or ``UNKNOWN`` when unset/unrecognized.r,) isinstancer r- ValueErrorrr%s&rr#r#BsR*011*!:#3#3":":"<== *!)))*s ==AAc$V^8dQhRRRRRR/#)rapi_call_countrmax_iterationsrr*r )r s"rr!r!Ls& N Nc N3 N3 Nrc\V4pV\P8d\ RVR7#\ RWR7# \\3d\PpLRi;i)a'``iteration N/M`` for user-facing status lines, or ``iteration N`` when the cap is unbounded. ``AIAgent.max_iterations`` defaults to ``sys.maxsize`` (unlimited), so printing the pair verbatim shows ``iteration 3/9223372036854775807`` in busy acks, heartbeats and timeout diagnostics (#102806). z$display.iteration_progress.unbounded)nz"display.iteration_progress.bounded)r:max)int TypeErrorr5sysmaxsizer)r7r8caps&& rformat_iteration_progressrALsZ .! ckk7>JJ 1^ MM z "kks <!A A c V^8dQhRRRR/#)ragentrrNoner )r s"rr!r![s8888rc|\\4;_uu_4RVnRRR4R# +'giR#;i)zClear the persist rate-limit so the next stamp writes through (terminal compression labels must not stick on mid-compress text).N)r Exception#_session_activity_last_persist_mono)rCs&r%reset_session_activity_persist_windowrI[s$ )  471    s* ; last_activity_provenancenowextrac 0V^8dQhRRRRRRRRRR R R /#) rlast_activity_atzOptional[float]last_activity_descriptionr)rJrrKrLzOptional[Mapping[str, Any]]rzdict[str, Any]r )r s"rr!r!asG% -A    ' rcVe \V4MRp\VeTM\P!44p\V4p\V4PpRTRTRTRVe\ We, ^4MRRVRVRVR V/T;'g/C#) zABuild the shared activity snapshot (plus optional caller extras).NrNrOrJseconds_since_activitylast_activity_tslast_activity_descr(r)floattimer1r#valueround) rNrOrJrKrLwhenclockdescprovs $$$$$ rbuild_activity_snapshotr\as'7&B5! "D #diik :E %&? @D ()A B H HDD#T"D D DJrc V^8dQhRRRR/#)ridle_srTrr )r s"rr!r`s11e11rc \P!4\P!4r2\RW P, W0P, , 4pWVP, 8dRVnV;P V, unW#uVnVn\R\ VP W,44Vn\RWP , 4#)zIReturn *idle_s* minus the sleep observed since the agent's last activity.rF)rUrbr;rcrdremin)rfrjwallmonoslept_ss&& rmeasureAwakeIdleMeter.measuresYY[$.."2dcD::-$2CDE 4::% % DN '!!% DJS#dnnf6F"GH3/00r)rerdrcN)r rrrrrgrprr rrr^r^ys11rr^)r __future__rr>rU contextlibrenumrtypingrrr agent.i18nrr//SESSION_ACTIVITY_HEARTBEAT_MIN_INTERVAL_SECONDSr*r frozensetrrrr$r&r1r#rArIr\r^r rrrysf# )) 37/ >d >,$-445555$ Y k * N8 DH    *. 011r