+ jHj, Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t H t ]P!]4t^"format_interval..=s1_%,$7UY>]^K^-GtO$VH-%s//s))rd)rh)<r&)r next)r'unitssf rformat_intervalr89s.'lG 2E _%_dkcllman oorc]tRt^@t$RtR]R&R]R&RtR]R&RtR ]R &RtR ]R &^t R]R &R Rlt ] RRl4t RRRllt RRltRtR#)HeartbeatStatez#Serializable per-session heartbeat.rr r r r r rr!rrrcV^8dQhRR/#rrrr)rs"rrHeartbeatState.__annotate__Ks<<#<# Cd CrcV'gR#\4pVf^RIHpV!RRV4R#VP\V,VP 44R# \ d"p\PRT4Rp?R#Rp?ii;i)N)_warn_dropped_writeHeartbeatManager heartbeatz%HeartbeatManager: set_meta failed: %s) rmrnrset_metarzrDrorprq)rur}r|rrss&& rsave_heartbeatrsk   B z8. ZHC L:-u}}? C z0J 8<rcV^8dQhRR/#rrrvr)rs"rrrs/rc VP#rb)rrBs&rr}HeartbeatManager.states {{rcV^8dQhRR/#rrrWr)rs"rrrsVVtVrc `VPRJ;'dVPPR9#)N>r pausedrr rBs&r has_heartbeatHeartbeatManager.has_heartbeats){{$&UU4;;+=+=AU+UUrcV^8dQhRR/#rr)rs"rrrsJJ4Jrc `VPRJ;'dVPPR8H#)Nr rrBs&r is_activeHeartbeatManager.is_actives({{$&II4;;+=+=+IIrcV^8dQhRR/#r<r)rs"rrrs Q QS Qrc VPpVfR#\VP4pVP'dRVP R2MRpVPR8Xdw\ ^\ VP;'g VPVP,\P!4, 44pRV RV RV R VP 2#VPR 8XdR MRpV R VP R V V R VP 2#)Nz@No heartbeat. Set one with /heartbeat every .z, fired ×r r u♥ Heartbeat (every z , next in ~r2z): ru⏸ z Heartbeat (z, every ) rr8r rr maxr rrrYr )rCr2everyfirednext_inicons& r status_lineHeartbeatManager.status_lines KK 9U 2 23/0|||(1<<.+ 88x !S!//"A"AQ\\QEWEW!WZ^ZcZcZe!efgG*5'WIQugSQRQYQYPZ[ [X-v2{188*HUGE7#ahhZPPrc$V^8dQhRRRRRR/#)rr rr r rr:r)rs"rrrs!  #   rc RT;'gRP4pV'g \R4h\V4pV\8d\R\ R24h\ WR\ P !4R7Vn\VPVP 4VP #)r zheartbeat prompt is emptyzinterval must be at least r2r )r r r r) strip ValueErrorr r%r:rYrrru)rCr r s&&&rsetHeartbeatManager.sets,,B%%'89 9/0 2 29:N9OqQR R$F^f04 = t 4{{rreanchorFc$V^8dQhRRRRRR/#)rr rrrWrrvr)rs"rrrs"#DE]rc VP'gR#WPnV'd%\P!4VPn\ VP VP4VP#rb)rr rYrrru)rCr rs&&$r _set_statusHeartbeatManager._set_statussI{{{#  (, DKK %t 4{{rcV^8dQhRR/#rr)rs"rrrs**/*rc $VPR4#)rrrBs&rpauseHeartbeatManager.pauses))rcV^8dQhRR/#rr)rs"rrrs9909rc (VPRRR7#)r T)rrrBs&rresumeHeartbeatManager.resumes488rcV^8dQhRR/#rr)rs"rrrstrc :VPR4RJpRVnV#)rxN)rr)rCrxs& rclearHeartbeatManager.clears#""9-T9 rNc V^8dQhRRRR/#)rrUrVrz Optional[str]r)rs"rrrs!!o!!rc LVPpVeVPV4'gR#VPVP3VnVeTM\ P !4VnV;P^, un\ VPV4VP4#)aReturn the injection prompt if the heartbeat is due, else None. The fire is recorded immediately (before the turn runs) so overlapping polls or a long turn can never double-fire the same tick. Missed ticks coalesce: the anchor resets to NOW, not the theoretical schedule. N) rrZrrrrYrrur`)rCrUr2s&& r due_promptHeartbeatManager.due_promptsr KK 9AHHSMMOOQ\\:!$#diik  t*  rcV^8dQhRR/#rr)rs"rrrsdrc ^VPVPr!VeVfR#\VP4pVeEVPR8wg4VP VP 3VP VP 38wdR#VwVnVnRVn\VPV4R#)u+Rewind the fire recorded by the last :meth:`due_prompt` whose turn never started, so the tick stays due for the next poll instead of being silently consumed. Mirrors ``LoopManager.abandon_tick``. Skipped (False) when the persisted state moved on — a pause/resume/clear that landed in between wins.NFr T)rrr~rur rrr)rCclaimr2currents& r abandon_fireHeartbeatManager.abandon_fires##T[[q =AI 1 ?gnn8W=R=RT[TfTf3S ~. =N>:F~-  ~-  =sCsAA B"A>>B)r2secsecssecondr')r&minminsminuteminutes)r4hrhrshourhours)r3daydays) r_r% POLL_SECONDSrr:r8r~rr(r)(rg __future__rr@loggingrerY dataclassesrrtypingrr getLoggerrcrpr%rr_compile IGNORECASErdictfromkeysr#rr r!rJr(r8r:rmrzr~rrrr__all__rrrrsZH#  )   8 $ Y zzoqsq~q~@  mm=qA mm=rB mm7> mm(%0   sBi+c1Xx#x5#,%|cSTX =p uu u6 I"  CaaH( r