+ lHjaRt 0tRt^RIt^RIt^RIt^RIHt^RIHt]P!] 4t ]!R4t ] 'd] P]P4]!4t]^k/t]^k]!4t]^k]P&!4t]P*!RRR7t]^kRRR/RR llltR R ltR R ltRRltRRltRRltRRltRRltRRltR#)a-Per-thread interrupt signaling for all tools: thread-scoped so interrupting one agent session does not kill tools in other sessions (the gateway runs many agents in one process). The agent passes its execution thread id to set_interrupt(); tools call is_interrupted(), which checks the CURRENT thread.N)Callable)env_var_enabledHERMES_DEBUG_INTERRUPThermes_interrupt_acting_for_tid)defaultreasonc\V^8dQhR\R\R,R\R,RR/#)active thread_idNrreturn)boolintstr)formats"4/home/ubuntu/.hermes/hermes-agent/tools/interrupt.py __annotate__r%s7FF$F3:FtF_cFcZVeTM\P!4Pp\;_uu_4V'd\P M\P !V4V'dV'd V\V&M\PVR4V'g\P V4\'d\\4MRpRRR4\'d8\PRW\P!4PX4R#R# +'giLU;i)zSet or clear the interrupt for *thread_id* (default: current thread); ``reason`` is an optional user-safe cause. Clearing also drops a pending yield request.Nz[[interrupt-debug] set_interrupt(active=%s, target_tid=%s) called_from_tid=%s current_set=%s) threadingcurrent_threadident_lock_interrupted_threadsadddiscard_interrupt_reasonspop_yield_threads_DEBUG_INTERRUPTsetloggerinfo)r r rtid _snapshots&&$ r set_interruptr%%s!,))2J2J2L2R2RC %+  ! !1E1M1M MsS f&, s #  " "3 -  " "3 '1A1AC,-t    0 113999 F s#6D+D3'D D<D D* c$V^8dQhR\/#)r r )r )rs"rrr9srrrrc\\P!4P4;'g\\P 44#N)is_thread_interruptedrrracting_for_tidgetrris_interruptedr-9s4 !9!9!;!A!A B q qF[\j\n\n\pFqqrc>V^8dQhR\R,R\/#r r Nr rr )rs"rrr=s 1 1S4Z 1D 1rczVfR#\;_uu_4V\9uuRRR4# +'giR#;i)zWhether *thread_id* has an interrupt bit set (``None`` never is). Used when a wait moves onto a deadline worker (``run_bounded_sync``) so ``/stop`` targeting the original tool-worker tid still kills the subprocess. See #94285. NF)rrr s&rr)r)=s' 00  ) : c(V^8dQhR\RR/#)r r r N)r)rs"rrrJs&&S&T&rc\;_uu_4\PV4RRR4R# +'giR#;i)aKAsk the tool running on *thread_id* to yield: a foreground terminal command hands its live process to the background registry and returns at once, so a user's mid-turn message (``redirect()`` during tool execution) is delivered instead of parked behind it. The command itself is never killed; that is what ``set_interrupt`` is for.N)rrrr2s&r request_yieldr6Js# 9% s / A c>V^8dQhR\R,R\/#r/r0)rs"rrrSs++t++rczVfR#\;_uu_4V\9uuRRR4# +'giR#;i)z?Whether a yield is pending for *thread_id* (``None`` never is).NF)rrr2s&ris_thread_yield_requestedr9Ss$ N* r3c>V^8dQhR\R,R\/#r/r0)rs"rrr[sS4ZDrcVfR#\;_uu_4V\9d!\PV4RRR4R#RRR4R# +'giR#;i)zKAtomically take the pending yield for *thread_id*; True if one was pending.NFT)rrrr2s&r consume_yieldr<[sA   &  " "9 -  s"A A  A cBV^8dQhR\.R3,R\/#)r callbackNr )rr )rs"rrrfs#  Xb$h%7 D rc\P!4Pp\;_uu_4V\9d RRR4R#V!4RRR4R# +'giR#;i)aRun a state transition atomically with current-thread interruption. Returns ``False`` without calling ``callback`` when the current thread is already interrupted. The callback runs under the interrupt lock and must not block or re-enter any interrupt API. NFT)rrrrr)r>r#s& rrun_if_not_interruptedr@fsF  " " $ * *C  & &    s AA A( c2V^8dQhR\R,/#r r N)r)rs"rrrusHHcDjHrc\;_uu_4\P\P!4P 4uuRRR4# +'giR#;i)z;User-safe interrupt cause for the current thread, if known.N)rrr+rrrr,rrget_interrupt_reasonrDus0 !%%i&>&>&@&F&FG s 2A  A cV^8dQhRR/#rBr,)rs"rrr{src\R4R#)awClear any interrupt bit on the CURRENT thread: gives a user-approved command a clean slate right before it spawns its child, so a stale bit that landed during the blocking approval-wait cannot SIGINT the just-approved run. A *genuine* interrupt arriving after this call re-sets the bit and is still observed by the executor's poll loop. Call directly on the executing thread.FN)r%r,rrclear_current_thread_interruptrG{s %rc>V^8dQh/^\9d\\,;R&^\9d\\\3,;R&^\9d\\,;R&^\9d&\ P \R,,;R&#)r rrrNr*)__conditional_annotations__r rdictr contextvars ContextVar)rs"rrrsw66,'&c#h&-6.('DcN'/64! C 56> &&sTz2?6rr()!rI__doc__rKloggingrcollections.abcrutilsr getLogger__name__r!rsetLevelINFOr rrrLockrrLr*r%r-r)r6r9r<r@rDrGr)rIs@rrVs6 $!   8 $##;< OOGLL!"%&%''5 6A5K5K%t6 FVZFF(r 1&+ H r