+ jHj;vRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t H t H t H t ^RI HtHtHtHtHt]P&!]4t^t^dt^lt:!R?R@4t;RARBltRGRHlt?/]@PRTRI4CRJ]>RK]?/C]@PRURL4C]@PRVRM4CtBRNR/RORPlltC.RWOtDR#)XuRecurring in-session wakeups — the /loop command (Claude Code parity). A loop stops when the agent ends a wakeup reply with ``LOOP_COMPLETE`` on its own line, when ``--times N`` ticks have fired, when the ``--until`` judge rules the condition met, or when the ``loops.max_ticks`` backstop pauses it. State lives in SessionDB ``state_meta`` (same contract as ``hermes_cli/goals.py``); CLI, gateway, and TUI all drive it through :class:`LoopManager`. ) annotationsN) dataclassfieldfieldsasdict)AnyDictListOptionalTuple LOOP_COMPLETEz (?im)^\s*z \s*[.!]?\s*$z)^(?=\d)(?:(\d+)h)?(?:(\d+)m)?(?:(\d+)s)?$u[/loop wakeup #{tick}{cadence}] Recurring task: {prompt} This is an automatic wakeup from the /loop the user set. Perform the task now against the CURRENT state (re-check files, processes, or services fresh — do not assume anything from earlier iterations still holds). Report concisely what you found or did this iteration. If the task is now complete, no longer applicable, or the thing you were watching has finished, say so and end your reply with u) on its own line — that stops the loop.u[/loop wakeup #{tick}{cadence}] Recurring task: {prompt} Stop condition: {until} This is an automatic wakeup from the /loop the user set. Perform the task now against the CURRENT state (re-check files, processes, or services fresh — do not assume anything from earlier iterations still holds). Report concisely what you found or did this iteration, and show concrete evidence of the stop condition's status. If the stop condition is met, or the task is no longer applicable, say so and end your reply with c V^8dQhRRRR/#)tokenstrreturn Optional[int])formats"5/home/ubuntu/.hermes/hermes-agent/hermes_cli/loops.py __annotate__rGs ( ( ( (cV'd$\PVP44MRpV'gR#RVP44wr#pVR,V^<,,V,pV^8dV#R#)zTotal seconds for ``30s``/``5m``/``2h``/``1h30m``, else None. A bare number is NOT an interval (it collides with prompt text like ``/loop 3 things``). Nc3J"TFq'd \V4M^xK R#5i)N)int).0gs& r 'parse_interval_token..Os8Z1Q!#Zs!#)_INTERVAL_TOKEN_REmatchstripgroups)rmhmntstotals& rparse_interval_tokenr*Gsa 49  /dA 8QXXZ8IAA HsRx ! #EAI5'4'rc V^8dQhRRRR/#)rtextrrdict[str, Any]r)rs"rrrTs)c)c#)c.)crc 8T;'gRP4pRRRRR^RRRR/pV'g /VCRR/C#^RrC\P!R V4pV'db\VP ^44pV^8d\ hTRTP 4YP4R,P4p\P!R V\P4pV'dAVP ^4P4pVRVP 4P4pVPR^4pV'dHV^,P4R 8Xd,\V4^8dV^,pVPR^4pV'd\V^,4MRpVe*\V4^8dV^,P4MRpV'g /VCRR /C#/VCRVRVRVRV/C# \ d/TCRR TP ^4: 2/Cu#i;i)zParse ``/loop [interval] [--times N] [--until ...]``. Returns ``{"interval_seconds": int|None, "prompt", "times", "until", "error"}``; ``interval_seconds`` None means self-paced, ``error`` is set for unusable input. interval_secondsNprompttimesuntilerroremptyz\s--times\s+(\S+)z(--times expects a positive integer, got z\s--until\s+(.+)$everyz1missing prompt (usage: /loop [interval] )) r#researchrgroup ValueErrorstartendDOTALLsplitlowerlenr*) r,rawresultr2r3m_timesm_untiltokensintervals & rparse_loop_argsrGTs ::2   C0$"gqRY[]_fhlmF +&+'7++b5ii,c2G h a()Eqy  $W]]_%KKMN(;;BBDii,c299=G a &&(#GMMO$**,YYtQ F &)//#w.3v;?Qi4#28#F1I.dH#&v;?fQioo W&W'#VWW bf b((Hc7ESZ\a bb+ hgfgg)QRYR_R_`aRbQe'fg g hs'G00&HHc V^8dQhRRRR/#)rsecondsfloatrrr)rs"rrrs  U s rc 4\\\^\V444R4wr\V^<4wr4V'dV R2.M.pV'dVP V R24V'g V'gVP V R24RP V4#)uBRender seconds as a compact human interval (``90`` → ``1m30s``).r r&r%r(r/)divmodrmaxroundappendjoin)rIr&remr%r(partss& rformat_intervalrSsx CAuW~./ 6FA #r?DAs!WIE s!W s!W 775>rcV^8dQhRR/#)rrr-r)rs"rrrs~rc^RIHpV!4;'g/PR4;'g/p\V\4'dV#/# \ d/u#i;i)r) load_configloops)hermes_cli.configrVget isinstancedict Exception)rVsections r _loops_configr^sW1=&&B++G4::$Wd33w;;  s!A A A A AAc(V^8dQhRRRRRRRR/#)rkeyrdefaultrfloorrr)rs"rrrs(S3ssrc \V\\4PW444# \dTu#i;i)zM``loops.`` as an int clamped to ``floor``; ``default`` on any bad value.)rMrr^rYr\)r`rarbs&&&r _config_intrds:5#mo11#?@AA s +. >>cV^8dQhRR/#rrrr)rs"rrrsPPcPrc$\R\^4#)min_interval_seconds)rdDEFAULT_MIN_INTERVAL_SECONDSrrrrhrhs -/KQ OOrcV^8dQhRR/#rfr)rs"rrrs::3:rc$\R\^4#) max_ticks)rdDEFAULT_MAX_TICKSrrrmax_ticks_defaultrns {$5q 99rcV^8dQhRR/#rfr)rs"rrrsYY#Yrc$\R\^ 4#)self_paced_floor_seconds)rd DEFAULT_SELF_PACED_FLOOR_SECONDSrrrrqrqs 13SUW XXrcV^8dQhRR/#rfr)rs"rrrsllClrcL\4p\R\V\4V4#)self_paced_ceiling_seconds)rqrdrM"DEFAULT_SELF_PACED_CEILING_SECONDS)rbs rrurus# $ &E 3S@b5cej kkrcN]tRt^t$RtR]R&RtR]R&RtR]R&RtR ]R &Rt R ]R &^t R ]R &Rt R]R&] t R ]R&^tR ]R&RtR ]R&RtR ]R&RtR ]R&RtR]R&RtR]R&RtR]R&RtR]R&]!]R7tR]R&R R!lt]R"R#l4tR$R%ltR&R'ltR(tR#)) LoopStatez,Serializable /loop state stored per session.rr1activestatusrFmoderJr0 current_delayrr2r/r3rl ticks_fired created_at last_fired_at next_due_atFboolawaiting_responselast_response_digestN Optional[str] paused_reasonlast_stop_reason)default_factoryzdict[str, str]routecV^8dQhRR/#rrrr)rs"rrLoopState.__annotate__s<<?@@rcV^8dQhRR/#rr)rs"rrrsXXXrc VPR8wdR#VP\P!4, pV^8:dR#R\V4 2#)ryr/zdue nowznext in )rzrtimerS)r remainings& rremaining_labelLoopState.remaining_labelsE ;;( "$$tyy{2 %NyW(?9;U:V0WWrr)__name__ __module__ __qualname____firstlineno____doc____annotations__rzr{r0r}r2r3rmrlr~rrrrrrrrr[rr classmethodrrr__static_attributes__rrrrxrxs6 KFCD#!e!M5E3NE3O&Is&KJM5K$t# "#"#'M='&*m*"$7E>7<$A XXrrxzloop:c V^8dQhRRRR/#)r session_idrrr)rs"rrrs))#)#)rc\ V 2#N) _META_PREFIXrs&r _meta_keyrs^J< ((rcV^8dQhRR/#)rrz Optional[Any]r)rs"rrrs   rc|^RIHpV!4# \d"p\P RT4Rp?R#Rp?ii;i)aBThe goals module's cached SessionDB, so goals/loops/heartbeats share one connection and its off-loop bootstrap (a cold cache on the loop thread never runs ``SessionDB()`` inline). The previous copy here did, which froze the loop for the init duration and dropped the first ``loop:*`` write (the /goal bug class, #88965). )_get_session_dbz,LoopManager: SessionDB bootstrap failed (%s)N)hermes_cli.goalsrr\loggerdebug) _goals_dbexcs rrrs8A ;  CSIs ;6;cV^8dQhRR/#)rlabelrr)rs"rrrs#rcrV!4# \d#p\PRY4TuRp?#Rp?ii;i)zLRun one SessionDB call; any error is logged at debug and yields ``default``.zLoopManager: %s failed: %sN)r\rr)rfnrars&&& r_db_oprs2t  15>s 6166r/c$V^8dQhRRRRRR/#)rrArrrOptional[LoopState]r)rs"rrr s"cs4Grc\PV4# \d*pT'd\P RY4Rp?R#Rp?ii;i)zW``LoopState`` from stored JSON; None (warning when *session_id* given) on corrupt data.z3LoopManager: could not parse stored loop for %s: %sN)rxrr\rwarning)rArrs&& r _parse_stater s>""3''   NNPR\ bs A AA c V^8dQhRRRR/#)rrrrrr)rs"rrrs::#:"5:rcaaS'd \4MRoSfR#\RVV3Rl4pV'd \VS4#R#)z4Load the loop for a session, or None if none exists.Nget_metac8<SP\S44#r)rr)dbrsrload_loop..sR[[:1F%Gr)rrr)rrArsf @r load_looprs8( dB z G HC,/<Z (9T9rc$V^8dQhRRRRRR/#)rrrstaterxrNoner)rs"rrrs& T T# Ti TD TrcaaaS'gR#\4oSf^RIHpV!RRS4R#\RVVV3Rl4R#)z5Persist a loop to SessionDB. No-op if DB unavailable.N)_warn_dropped_write LoopManagerloopset_metacV<SP\S4SP44#r)rrr)rrrsrrsave_loop..(sr{{9Z+@%--/Rr)rrrr)rrrrsff @r save_looprs3   B z8M6:> :RSrc V^8dQhRRRR/#)rrrrrr)rs"rrr+s%%3%4%rcL\V4pVeRVn\W4R#R#)zDMark a loop cleared in the DB (preserved for audit, status=cleared).Ncleared)rrzr)rrs& r clear_loopr+s& j !E   *$rcV^8dQhRR/#)rrzlist[tuple[str, LoopState]]r)rs"rrr3s6rca\4oSf.#.p\RV3Rl.4F_wrV\\4RpV'dV'd \ V4MRpVfK:VP R8XgKMVP W434Ka V#)z``[(session_id, LoopState), ...]`` for every ACTIVE loop; ``[]`` on any DB error. Used by the gateway's idle wakeup watcher, which scans for due loops on a coarse tick. Nlist_meta_prefixc.<SP\4#r)rr)rsrr#list_active_loops..<sr7J7J<7Xrry)rrr@rrrzrO)outr`rArrrs @rlist_active_loopsr3s~  B z ')C-/XZ\]\*+, %/C S!T  !9 JJ * + ^ Jrc V^8dQhRRRR/#)rrrrrr)rs"rrrDscdrcVP\4FBwrV'd\W!\\4R4MRpVeVPR8XgKAR# R#)uTrue when *db* holds an ACTIVE ``loop:*`` row — or a row that cannot be parsed (unknown, so the caller keeps its full scan). Unlike :func:`list_active_loops` this takes the store explicitly and propagates read errors, so an idle gate can tell "empty" from "unavailable".NryTF)rrrr@rz)rr`rArs& rstore_has_active_looprDsN'' 5>A Sc,&7&8"9:t =ELLH46 rreasonc(V^8dQhRRRRRRRR/#)rold_session_idrnew_session_idrrrr)rs"rrrOs*CQT^brcbV'dV'dW8XdR#\V4pVeVPR8Xg\V4eR#\W4\V4\P RYT;'gR4R# \ d"p\P RT4Rp?R#Rp?ii;i)alCarry a /loop from a parent session to its continuation. Best-effort, never raises. Context compression rotates ``session_id`` to a fresh child; without this the loop silently dies at the compaction boundary. Copies the loop onto the new session and archives the old row as ``cleared`` so exactly one active loop row exists per logical conversation. See #33618. FNrz(LoopManager: migrated loop %s -> %s (%s)rotationTz&LoopManager: loop migration failed: %s)rrzrrrrr\)rrrrrs&&$ rmigrate_loop_to_sessionrOs >3S .) =ELLI5>9R9^.(>" 6 F,@,@j   =sCs-B 7B B. B))B.c V^8dQhRRRR/#)rnrrrr)rs"rrrjs..C.C.rc&T RV^8wdR 2#R 2#)z tickr(r/r)rs&r _ticks_labelrjs%SQ!Vc, --, --rc V^8dQhRRRR/#)rrrrrr)rs"rrrns..-.C.rc V'dRV 2#R#) — r/rrs&r_dashrns%U6( -2-rc V^8dQhRRRR/#)rresponserrrr)rs"rrrrsMMMMrcV\V4;'d\PV4RJ#)zBTrue when the agent ended its reply with the LOOP_COMPLETE marker.N)r_LOOP_COMPLETE_REr8)rs&rresponse_signals_completerrs% > L L/66x@LLrc V^8dQhRRRR/#)rrrrr)rs"rrrwsGGsGsGrczT;'gRP4P4p\P!RRV4p\P!RRV4p\P!RRV4p\P!RRV4p\P !VP RR44P4#) zDigest for self-paced change detection; whitespace-normalized with clock/timestamp/duration tokens stripped so 'checked at 14:02:33' doesn't defeat the backoff.r/z\d{1,2}:\d{2}(:\d{2})?z\d{4}-\d{2}-\d{2}zH\b\d+(\.\d+)?\s*(s|sec|secs|seconds|m|min|mins|minutes|h|hr|hrs|hours)\bz\s+ zutf-8replace)r#r?r7subhashlibsha256encode hexdigest)rr,s& r_digest_responser ws NN ! ! # ) ) +D 66+R 6D 66&D 1D 66]_acg hD 66&#t $D >>$++gy9 : D D FFrc]tRtRtRtRRlt]RRl4tRRltR R lt R R lt R Rlt RRlt RRR^RRRR/RRllt R*RRlltRRltRRltR+RR lltR!R"ltR#R$ltR%R&ltR'R(ltR)tR#),riaPer-session /loop state + tick decisions. Drivers call ``set``/``pause``/``resume``/``clear`` for user controls, ``is_due()`` (cheap, in-memory), ``fire_tick()`` to claim a tick and get the wakeup message, ``complete_tick()`` to evaluate the finished turn, and ``status_line()``. cV^8dQhRR/#)rrrr)rs"rrLoopManager.__annotate__sAA3Arc 2Wn\V4VnR#r)rr_state)rrs&&r__init__LoopManager.__init__s$+4Z+@ rcV^8dQhRR/#rrrr)rs"rrrs*rc VP#r)rrs&rrLoopManager.states {{rcV^8dQhRR/#rrrr)rs"rrrs111rc :\VP4VnR#)zARe-read state from the DB (cross-process safety for the gateway).N)rrrrs&rrefreshLoopManager.refreshs0 rcV^8dQhRR/#rrrr)rs"rrrsJJ4Jrc `VPRJ;'dVPPR8H#)Nryrrzrs&r is_activeLoopManager.is_actives({{$&II4;;+=+=+IIrcV^8dQhRR/#rr)rs"rrrsVV$Vrc `VPRJ;'dVPPR9#)N>rypausedr!rs&rhas_loopLoopManager.has_loops){{$&UU4;;+=+=AU+UUrcV^8dQhRR/#)rrrxr)rs"rrrsyrc Z\VPVP4VP#r)rrrrs&r_saveLoopManager._saves$//4;;/{{rcV^8dQhRR/#rr)rs"rrrs88S8rc VPpVeVPR8XdR#\VP4pVP'dVP RVP R2.pM3VP 'dVP RVP R2.pMV.pVP 'dVPRVP 24VP4 RRPV4 2pVPR8XdHVP4pVP'dR MV'dRV 2MR pR V V R VP 2#VPR 8Xd(RV \VP4 R VP 2#VPR8Xd(RV \VP4 R VP 2#RVP RV R VP 2#)Nrz6No loop set. Start one with /loop [interval] ./ runsz budgetzuntil: , ryz, wakeup runningr/u↻ Loop (active, ): r&u⏸ Loop (paused, doneu✓ Loop finished (zLoop ()rrzrr~r2rlr3rOrrPrrr1rrr)rr(firedcapsmetartails& r status_lineLoopManager.status_lines KK 9I-KQ]]+ 777}}oQqwwiu56D [[[}}oQq{{m7;ryr&)rrzrrr+)rrr(s&& rpauseLoopManager.pauses@ KKAHH$889A656!/1#6zz|rcV^8dQhRR/#rr)rs"rrrs+rc VVPpV'dVPR8XdR#RRRuVnVnVnVP;'gVP ;'g \ 4p\P!4\VR4,Vn VP4#)rNryFg@) rrzrrr}r0rqrminrr+)rr(delays& rresumeLoopManager.resumesz KKAHH )9A46!/1#6SS1#5#5SS9Q9S c%o5 zz|rcV^8dQhRR/#rr)rs"rrrstrc VPeVPPR8XdR#RVPnVP4RVnR#)NrFT)rrzr+rs&rclearLoopManager.clears? ;; $++"4"4 "A&   rc V^8dQhRRRR/#)rr=zOptional[float]rrr)rs"rrrs  / T rc VPpVRJ;'dYVPR8H;'dBVP'*;'d)VeTM\P!4VP8#)z>Cheap check: active, not mid-wakeup, and the clock has passed.Nry)rrzrrr)rr=r(s&& ris_dueLoopManager.is_duesi KK TM K Kahh(2 K K1;N;N7N K KTYY[Q]]J rcV^8dQhRR/#)rrrr)rs"rrrsdd=drc VPpVeVP4'gR#V;P^, un\P!4VnRVnVPVP ;'gVP;'g \4,Vn VP4VPP4PR4'dVPP4#VPR8XdRVP!4 2MRpVP"'d\$M\&pVP)VPW!PVP"R7#)a@Claim a due tick; returns the message to inject, or None. The message is the wakeup-framed prompt, or the raw command when the loop's prompt is itself a slash command (``/loop 10m /recap``). Marks ``awaiting_response`` so the tick can't double-fire; drivers MUST follow up with ``complete_tick`` (or ``abandon_tick``). NTr/rFr1z , self-paced)tickcadencer1r3)rrPr~rrrr}r0rqrr+r1lstrip startswithr#r{rr3!WAKEUP_PROMPT_WITH_UNTIL_TEMPLATEWAKEUP_PROMPT_TEMPLATEr)rr(rUtemplates& r fire_tickLoopManager.fire_ticks KK 9DKKMM  ))+"1??+n+na>P>P+n+nTlTno  88??  ' ' , ,88>># #./ff .BBq()*894E[AMM788[\[b[bccrcV^8dQhRR/#rr)rs"rrrsdrc VPpVeVP'gR#RVn\^VP^, 4VnVP 4R#)z=arc  VPpVeVP'gRV'd VPMRRRRRRR/#RVn\P!4p\ VP 4p\ V4'dVPR R R V R 24#VP'dT;'gRP4'de^R I H pV!VPV4wrgrp VR 8XdVPR RV 2R V RV 24#VR8XdRV 2p VPRV RV R24#VP'dXVP VP8d=VPR RVP R2RVP RVP R24#VP 'deVP VP 8dJVPRRVP RVP R2RVP RVP R24#VP"R8Xdz\%V4p \'4pV 'dFWP(8Xd6\+\-VP.V4^,\144VnM\3V4VnWnMVP4VnW2P.,VnVP94RR RRRR!RR/# \d%p RR\T 4P 2rvRp ? ELRp ? ii;i)"zEvaluate the finished wakeup turn and schedule what's next. Returns ``{"status": "active|done|paused", "stopped": bool, "reason": str, "message": str}``; ``message`` is a user-visible one-liner, "" in the common still-looping case. NrzrdFrzno tick in flightrbr/r3z#agent signaled the task is completeu✓ Loop finished after u — task complete.) judge_goalcontinuezjudge unavailable: zstop condition met: rblockedz$stop condition judged unachievable: r&u⏸ Loop paused — z3. /loop resume to keep going, /loop stop to end it.zcompleted the requested r0u✓ Loop finished — ran r/z times.ztick budget exhausted ()zP ticks used (loops.max_ticks). /loop resume to keep going, /loop stop to end it.rryzloop continues)rrrzrrr~rrer3r#rrjr\rrr2rlr{r rqrrFrMr}rurJr0rr+)rrhr(r=ticksrjverdictr_pf_wait_tfrwhydigestrbs&& r complete_tickLoopManager.complete_tick%s KK 9A///!ahhy%Sfhqsuv v#iikQ]]+ %] 3 3::f&K 8?RSU U 777 ++2244 Y73=agg}3U0S& zz&,@*I$rBrHrLrPr[r_rerurrrrrrsA1JV80+/     +/@ d0 Y=a=arrc V^8dQhRRRR/#)rrrrrr)rs"rrres  c d rc^RIHpV!VR7pVP4;'dVP4'*# \dR#i;i)zTrue when an ACTIVE, non-parked /goal should defer this session's /loop tick. Both features inject synthetic turns at idle boundaries; interleaving them would burn the goal's turn budget. Parked (waiting), paused, or done goals do NOT block the loop. ) GoalManagerrF)rr{r" is_waitingr\)rr{mgrs& rgoal_blocks_loop_tickr~esD 0Z0}}77s~~'7#77 s%>> A  A uUsage: /loop [interval] [--times N] [--until ] /loop 5m check the deploy status — first run now, then every 5m /loop every 10m /recap — loop a slash command /loop keep fixing tests until green — self-paced (backs off while output is unchanged) /loop 2m poll CI --times 30 — stop after 30 runs /loop 5m watch the queue --until queue is empty Controls: /loop status · /loop pause · /loop resume · /loop stop The loop also stops itself when the agent replies with .c V^8dQhRRRR/#rr}rrrr)rs"rrrsrr{rsrrcRVPRR7pVfR#RVP R2#)rwrz No loop set.u⏸ Loop paused: z Use /loop resume to continue.)rBr1r}rs& r _pause_outputrs0 II]I +E"]>q2CELL>Qp0qqrc V^8dQhRRRR/#rr)rs"rrrstt ttrcnVP4pVfR#RVP4 RVP 2#)NzNo loop to resume.u▶ Loop resumed (r2)rHrr1rs& r_resume_outputrs> JJLE#(= s8J5K^K^K`Jaadejeqeqdr6ssrc"VP4#r)r8r}s&rrrs 0ArrBrHc6VP4'dR#R#)u✓ Loop stopped.zNo active loop.)rLrs&rrrsTWT]T]T_T_=P=vev=vrc\#r) LOOP_HELPrs&rrrs)rrc(V^8dQhRRRRRRRR/#) rr}rargsrrr;rr-r)rs"rrrs07979 79 79 $ 79  79rc T;'gRP4p\PVP44pVe RV!V4RR/#\ V4pVR,'d%VR,R8XdRRRR/#RR VR, 2RR/#VP 4pVP VR ,VR ,VR ,VR ,VR7pRTP4 RTP 2.p T'dT PR4TR ,eATR ,TP8d)T PR\TP4 R24TPR8Xd=T PR\TP4 R\\44 R24TP 'd6T PRTP RTP ^8wdRMR R24TP"'dT PRTP" 24TP 'g2TP$'d T PRTP$ R24TP&R8XdR MTP)4p T PR!T R"24RR#P+T 4RR$/# \dpRR T 2RR/uRp?#Rp?ii;i)%uSurface-agnostic handler for ``/loop `` → ``{"output": str, "created": bool}``. ``output`` is printed/sent verbatim by each surface. ``route`` is stored on new loops so the gateway's idle watcher can inject wakeups into the right chat; CLI/TUI pass None. r/NoutputcreatedFr4r5u4Usage: /loop [interval] — see /loop help.z/loop: r1r0r2r3)r0r2r3ru↻ Loop set (r2z-(replaced the previous loop for this session)z(interval raised to the u( minimum — loops.min_interval_seconds)rzSelf-paced: first check in z; backs off up to z while nothing changes.zRuns z timer(z , then stops.z Stops when: zBackstop budget: z( ticks (loops.max_ticks; 0 = unlimited).ryz$fires now, then on the cadence abovez First wakeup u4. Controls: /loop status · pause · resume · stop. T)r#_CONTROL_COMMANDSrYr?rGr'r>r:rr1rOr0rSr{r}rur2r3rlrzrrP) r}rrargcontrolparsed replacingrrlinesfirsts &&$ rdispatch_loop_commandrs ::2   C##CIIK0G'#, 599 S !F g '?g %TV_afg gGF7O#45y%HH I = 8 #$67//  e1134C ~ F GE DE  !-&9K2LuOeOe2e &u7M7M'N&OP* *  zz\! )/%:M:M*N)OP./I/KLMMd f  {{{ uU[[MekkQ6FsB.O}]^ {{{ |EKK=12 ;;;5??? ((99abc6;llh6N 2TYTiTiTkE LL='[\] dii& 4 881 =GC5/9e<<=s2J(( K3K;KKir)r/)r/rz)stoprLcancel)helpz--helpz-h)rmriLOOP_COMPLETE_MARKERrYrXrrxrrrSr~rrrr*rGrr)Er __future__rr rloggingr7r dataclassesrrrrtypingrrr r r getLoggerrrrirmrrrvrcompileescaper IGNORECASEr!rYrXr*rGrSr^rdrhrnrqrurxrrrrrrrrrrrrrrr rr~rrrr[fromkeysrr__all__rrrrs&#  8833   8 $ "$& %,"'JJ299122_DZZ0"-- BEG "#7!78 " ()cX P:Yl  9X9X 9Xx ) : T%"WY6..M G`a`aF  >A r t  mmN$AB ] n mm/1vw   mm,.CD 79'+ 79t r