+ iHj\LRt^RIt^RIt^RIt^RIHt^RIHt^RIH t ^RIH t ]P!R4tRtRtR t]!]]]04tR tR R ltR RltRRltRRltRRltRRltRRltRRltRRltRRltRR ltR!R"lt R#R$lt!!R%R&4t"R#)'zInterrupt / steer / redirect control surface for ``AIAgent``. Soft/hard interrupt requests, tool-thread interrupt propagation, pending steer/redirect queues. Extracted from ``run_agent.py``; every method resolves through ``AIAgent``'s MRO unchanged. N)Optional)request_hard_interrupt) request_yield) set_interrupt run_agentzexplicit stop requestedzuser sent a new messagezuser interruptzgateway shutdownc:V^8dQhR\\,/#returnrstr)formats">rc$V^8dQhR\/#rr)r s"rrr2saaarc8\V4pV'dRV R2#R#)zdTurn exit reason for an API call cut short by an interrupt (``turn_explainers`` matches the prefix).zinterrupted_during_api_call()interrupted_during_api_call)r)rissuers& r"interrupted_during_api_call_reasonr'2s$ e $F7= )& 3`C``rc4V^8dQhR\R\RR/#)r when_in_flight failure_logr N)boolr )r s"rrr8s"55$5S5UY5rcVe\\VRR44VJdR#\\V4RR4p\V4'd V!V4R#R# \d\ P TRR7R#i;i)u!Call ``type(fence).cancel_before_commit(fence)`` when ``commit_in_flight`` matches. Hard-cancel admission has two halves (#99758 P1). BEFORE the generation claim is consumed only a commit already in flight is waited out (the call blocks on the fence lock and returns False WITHOUT setting ``_cancelled``) — cancelling a still-pending fence there would be irreversible for an abort that may yet be declined. AFTER the claim survived, only a still-pending commit is cancelled; one that started meanwhile owns the fence and completes on its own.Ncommit_in_flightFcancel_before_commitTexc_info)r+rtypecallable Exceptionloggerdebug)fencer)r*r.s&$$ r_fence_cancel_before_commitr78su }WU,>FG~]"4;0FM$%% 5  '& 5 LLtL 4 5s A"A;:A;c$V^8dQhR\/#)r attrr)r s"rrrKs>>#>rcP\WR4pVf\P!4#T#)zY``with`` the lock stored at ``attr`` when present; __init__-less test stubs run unlocked.N)r contextlib nullcontext)rr9locks&& r_ic_lockr>Ks& 5 %D'+|: ! ! #==rc0V^8dQhR\R\/#)r lock_attrslotr)r s"rrrQs  s # rcL\WR4f \WR4#\W4#)a Read the pending-text ``slot`` guarded by ``lock_attr``. An initialized agent always has both attributes, so under the lock the slot is read directly and a missing one fails loud (a real bug); only ``__init__``-less test stubs (no lock) get the ``getattr`` fallback.N)r)rr@rAs&&&r_ic_slotrCQs)u&.uD)) 5 rc$V^8dQhR\/#rlist)r s"rrrZs4rc\VRR4p\V4PR4;'g.pRPRV44T;'gR8wdV'dRV3.#.#\ V4#)zThe buffered steers as ``(ticket, text)`` pairs; ``_pending_steer`` is their newline join. A ticket names one submission (a gateway transfer). A buffer another writer set directly is one ticketless part._pending_steer_lock_pending_steer_pending_steer_parts c3*"TF wrVxK R#5iN.0rtexts& r _steer_parts.._s+U'!UN)rCvarsgetjoinrF)rpendingpartss& r _steer_partsr[Zsju35EFG KOO2 3 9 9rE yy+U++ 2>$+w 33 ;rc(V^8dQhR\RR/#)r rZr NrE)r s"rrrdsHH4HDHrc`WnRPRV44;'gRVnR#)rKc3*"TF wrVxK R#5irMrNrOs& rrR#_set_steer_parts..fs$?gaTrTN)rJrXrI)rrZs&&r_set_steer_partsr`ds'!&99$?$??GG4Erc$V^8dQhR\/#r)dict)r s"rrris==4=rc8\V4PR/4#)z``{ticket: consumed}`` for ticketed steers that left the buffer: True when a drain handed the text to the turn, False when it was dropped unread. ``withdraw_steer`` reads each one once._steer_ticket_fates)rV setdefault)rs&r _steer_fatesrfis ; ! !"7 <rVpoprfr`r[)rrhdrainedrZticketrs&& rrequeue_drained_steerrnos %. / /e).__annotate__s " "$ "rcD<S\8Xd*\SRR4'd\SRR4\9gSSnSSnRSnRSn\PRS'dRMRS4S'd\SRR4MRpVeVP4R#R#) _interrupt_requestedFrNTzInterrupt requested (%s): %shardsoft_hard_interrupt_requested) _REASON_GATEWAY_SHUTDOWNrr_interrupt_messagerr_turn_user_intervenedr4infoset) _hard_eventrrselftool_interrupt_reasonrs r_publish_interrupt_stateAInterruptControlMixin.interrupt.._publish_interrupt_states #;;Ndfk@l@l&>EI__*1'.C+(,D %)-D & KK6+SY[p qNY'$(CTJ_cK&!'rcL<S'd\S4PR4#R#) _active_compression_commit_fenceN)rVrW)rrsr_fence/InterruptControlMixin.interrupt.._fencesIT4:>>"DE ^Z^ ^r_pending_redirect_lockTz)Compression hard-cancel fence wait failed)r)r*_turn_liveness_abort_claimz.Compression hard-cancel fence admission failedrequest_interruptz)Failed to interrupt Codex app-server turnr/interrupt_abortz%Failed to abort active inline request)r)rz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requestedz: ':N(Nz...''rU)_liveness_activity_lockrr_REASON_HARD_STOP_REASON_NEW_MESSAGE_REASON_USER_INTERRUPTr>r7_pending_redirectrvr3r4r5r{_execution_thread_idr _interrupt_thread_signal_pendingr_active_children_lockrF_active_childrenr interrupt quiet_modeprintlen) rrrrrrr_request_interrupt children_copychilders ffdd$ @rrInterruptControlMixin.interrupts  )--//4!EqIM__ 0/3E/03>[ - --]]"5F\   " "  _d4 5 5 ';f "))* 1133t%A4HL^^$46 57;D3,. 4 (rCrrrr threadingEventclearrrrrrr[rfr`)rrrrmrs&$$ rclear_interrupt%InterruptControlMixin.clear_interrupts d4 5 5 $8PRe)f)f6 5).D %DH HD #d&A D5y7H I O O Q$)-&616-  $ $ 0 5$";"; <e, $ 566!-d!3IF)5: T*62"4!r* 7 +6 5 76 s#D*AD*)D=D=* D: = E rmc&<V^8dQhRS[RS[/#r rQr r r+)r rs"rrr6s  # $ rc V'dVP4'gR#VP4p\VR4;_uu_4\V\V4W#3.,4RRR4RVnR# +'giL;i)aQueue user text for delivery as its own user row after the current tool batch finishes (no interrupt); multiple calls concatenate with newlines. Returns False for empty text. ``ticket`` names the submission, so ``withdraw_steer`` can settle exactly it, whatever text others carry.FrHNT)rr>r`r[r)rrQrmcleaneds&&$ rsteerInterruptControlMixin.steer6sb4::<<**, d1 2 2 T<#5&9J8K#K L3&*" 3 2s A55 B c&<V^8dQhRS[RS[/#rr)r rs"rrrCs==S=T=rc V'dVP4'gR#VP4p\VR4pVe_\VR4;_uu_4VP'd RRR4R#RRR4\ V!V44pV'dRVnV#\VRR4'dpVPV4pV'dU\VR R4p\VR R4pVe7Ve3V;_uu_4\V4pRRR4XFp\V4K V#\VR R4p \VR4;_uu_4V eV P4'g RRR4R#\VRR 4p VP'dV 'g RRR4R#V 'dV R V 2MTVnRVnRVnRVnRRR4\VRR4p V e\#RV 4RVnMRVn\'VRR4R# +'giEL;i \ d\PRRR7R#i;i +'giELK;i +'giL;i)aRedirect the active turn without converting it into a new task: during a model request only that request is cancelled (completed messages kept, partial reasoning becomes assistant context, the correction is appended as a real user message, the loop retries); during tool execution it degrades to ``steer()``; Codex app-server uses native ``turn/steer``. False when no live turn / empty text.F request_steerNrTz"Codex app-server turn/steer failedr/_executing_toolsrr_model_request_activerz [Additional user correction] rredirect_abortz$Failed to abort request for redirect)rrvr>rr+rr3r4r5rrrF_request_yieldis_setrCrrrrr{) rrQr _native_steeracceptedrrrr _model_activeexistingrs && rredirectInterruptControlMixin.redirectCs& 4::<<**,(?  $$ 899,,, :9,:  g 6715D. 4+U 3 3zz'*H!$(>E&t-H$O &<+C%&*7m &*&s+ +O&=tD d4 5 5$M,@,@,B,B6 5 &>@STH((( 6 5MU8*>wiHZa  ")-D %&*D #)-D &6 't-CTJ  + 4!5 649D 148D 1 '79_`e:99  AD Q &6 5sTH=!H7 III(&III"#I H "II I  I) c <V^8dQhRS[/#rr~)r rs"rrrsWWtWrc  \VR4;_uu_4\\VRR44uuRRR4# +'giR#;i)z@Return whether an active-turn redirect is waiting to be applied.rrN)r>r+rC)rs&r_has_pending_redirect+InterruptControlMixin._has_pending_redirects2 d4 5 5'?ATUV6 5 5 5s 6 A c0<V^8dQhRS[S[,/#rr )r rs"rrrs#rc \VR4;_uu_4\VRR4pRVnRRR4V# +'giX#;i)z5Return and clear pending active-turn correction text.rrN)r>rCr)rrQs& r_drain_pending_redirect-InterruptControlMixin._drain_pending_redirectsD d4 5 5D":rCr[r`rfrj)rrQrZrmrs& r_drain_pending_steer*InterruptControlMixin._drain_pending_steers} d1 2 2D"79IJD &E T2 &" %15L&v.#'+]D "3 3 2 s-A+A++ A< c0<V^8dQhRS[S[,/#rr )r rs"rrrsSSx}Src  \VR4;_uu_4\V4p\YUu.uFq"^,fKVNK up4RRR4RPRX44;'gR#uupi +'giL7;i)a The turn finalizer's drain: return and clear the ticketless steers (they become the next user turn) and keep each ticketed one buffered. A transfer is never a follow-up a restart may discard: settlement withdraws it and its admission goes back to its own queue place.rHNrKc36"TFwrVeK VxK R#5irMrN)rPrmrQs& rrR>InterruptControlMixin._drain_leftover_steer..sJ%,&6%s )r>r[r`rX)rrZparts& r_drain_leftover_steer+InterruptControlMixin._drain_leftover_steersnd1 2 2 &E TU#RUT1gDDU#R S3yyJ%JJRRdR$S3 2s!A7 A2A2A72A77 B c <V^8dQhRS[/#rr~)r rs"rrrs   rc nVfR#\VR4;_uu_4\V4pVUu.uFq3^,V8wgKVNK pp\V4PVR4p\ V4\ V48XdVRJuuRRR4#\ W4RRR4R#uupi +'giR#;i)a%Settle one ``steer(text, ticket=...)`` by identity (the gateway's transfer of a queued prompt): True when no drain handed it to the turn, either still buffered (taken out now; every other steer stays, whatever its text) or dropped unread; False once a drain consumed it, or for an unknown one.NFrHT)r>r[rfrkrr`)rrmrZrkeptconsumeds&& rwithdraw_steer$InterruptControlMixin.withdraw_steers > d1 2 2 &E%*@UT1g.?DDUD@#D)--fd;H4yCJ&5( 3 2 T ( 3 A3 2s'B#BB9B# B#B## B4 )rrrrrjrrrrM)__name__ __module__ __qualname____firstlineno____doc__rrrrrrrrrr__static_attributes____classdictcell__)rs@rrrsckDIk%)kOSkkZb\`bb 5V[@   ==~WW   SS  rr)#rr;loggingrtypingragent.interrupt_compatrtools.interruptrrrr getLoggerr4rrr frozensetrrrr!r'r7r>rCr[r`rfrnrvr{rrrNrrr s 9;;   ; ' ./)"$57JLb#cd-1 ?a 5&>  H = =05&PPr