+ lHjQ Rt^RIHt^RIt^RIt^RIHtHt]!4tRs ]P!4t Rt R;RRllt R;RRlltR;R R lltR zz~~12c9 BB@BGGHXY ZZrc$V^8dQhRRRRRR/#)rsessiondictrrr r r )r s"r rrs&VVV;V$Vrc\V4;'dQ\VPR44;'g/VPR4RJ;'dVPR4RJ#)_compute_host_activeagentN agent_ready)rr r)rrs&&r _session_uses_compute_hostr sc #3 ' V V W[[/ 01 U U KK D ( S SW[[-Gt-SVrcV^8dQhRR/#)rrrr )r s"r rr%s ( (k (rc RT;'g \4p\;_uu_4\fZ^RIHpT!\ \ VPR4;'g^4\ VPR4;'g^4R7s\uuRRR4# +'giR#;i)N)HostSupervisorcompute_host_heartbeat_secscompute_host_respawn_max)rpc_sinkheartbeat_secs respawn_max)r_compute_host_supervisor_lock_compute_host_supervisortui_gateway.host_supervisorr#_relay_compute_host_rpcintr)r isolation_cfgr#s& r _get_compute_host_supervisorr/%sEECEM & & # + B'50"=#4#45R#S#Y#YWYZ 1 12L M R RQRS(U $( ' & & &s2B"B9B B& c<V^8dQhRRRRRRRRRR R R R R RRRR/ #rridstrsidrrtextAny image_pathszlist[str] | Nonequeued_prompt_generationz int | None display_kind str | Nonedisplay_metadatarr r )r s"r rr2sc$F$F $F$F!%$F-0$F?O$F($F?I$F"$F.2$Frc!PVR,;_uu_4\VPR.44p\VPR^44p \VeTMVPR.44p RRR4RRRTRTR VPR 4;'gTR V/V'dR V/M/CRX/CV'dR V/M/CRX R \VPR ^P4;'g^P4R\V4R\ VPR44R\ V4RVPR4;'gRRVPR4RVPR4RVPR4RVPR4R\ V4RX R\V4RVR\V4/C# +'giEL3;i) history_lockhistoryhistory_versionNattached_imagestypez turn.startr4 request_id session_keyr5r9r;colscwd explicit_cwdcontext_cwd_is_launch_artifact profile_homemodel_overridepending_model_switchreasoning_config_overridecreate_reasoning_overrideservice_tier_overridecreate_service_tier_overridesource auth_user_idr8active_session_lease) listrr- _session_cwdr _context_cwd_is_launch_artifact_session_source_session_auth_user_id_active_session_lease_vouch) r2r4rr5r7r8r9r;r>r?r@s &&&&&&&& r _compute_host_turn_framerY2s  w{{9b12gkk*;Q?@k.E{7;;WhjlKmn !  eS,w{{=188S&$ F.:NL )r FENw F6F  0 12  F ?FC FB8O8U8USU4V |G$W[[89(*I'*R N399r'++&67  ,B C#W[[1L%M-K!L/'*,=-g6"$<  ;G D9 FF ! s AF F% c V^8dQhRRRR/#)rrrr rr )r s"r rrYs R R R+ RrcPVPR4pVe'\VRR4'g\VRR4'gR#\VP4\VPR4;'gR48wdR#R\VP4R \VP4/#) a``{lease_id, session_id}`` of the REAL registry lease this process holds for the session's current stored id, else None. Qualified, not a bare bool: after a compression rotation a lease still keyed on the old id must not let a (replacement) child borrow the continuation.rRNreleasedFenabledrCrIlease_id session_id)rgetattrr3r_r^)rleases& r rXrXYs KK. /E }z599PY[`AaAa 5  GKK $>$D$D" EE ENN+\3u?O?O;P QQrc V^8dQhRRRR/#)rrrr rr )r s"r rres66k6d6rclT;'g/PR4p\V\4'dV#/#)_metadata_mirrorr isinstancer)rmirrors& r rdrdes0mm !3 4F--6525rc V^8dQhRRRR/#)rrrr r )r s"r rrjs8888rc8\VPR4V4#)r) _session_inforrs&r _compute_host_session_inforljs W-w 77rc$V^8dQhRRRRRR/#)rrrframer Noner )r s"r rrns&UUDUU$Urc \VPR4;'gR4pV'dT\VPR4;'gR48wdp\\VPR4;'gR4WR7'g7\P RVPR4VPR4V4W R&VPR4ex\ P !\4;_uu_4\\VPR^44\VPR4;'g^44VR&RRR4R#R# +'giR#;i)udAdopt a host frame's session_key / history_version. Caller holds history_lock. A rotated ``session_key`` means the child compressed A->B. The child only holds an inert borrowed token (``_install_borrowed_lease``), so the REAL registry lease is re-anchored here, by its owner — never claimed from the child pid (authority stays singular, #103737 review).rCrIr4)new_session_idzWCompression session lease did not re-anchor: sid=%s old_session_id=%s new_session_id=%sr?N) r3r_transfer_active_session_slotloggerwarning contextlibsuppress Exceptionmaxr-)rrnnew_keys&& r _compute_host_adopt_frame_metarzns  %))M*00b1G7c'++m"<"B"BCC,S51A1G1GR-H'jj NNt 99U+W[[-G R!(  yy"#/   + +),S=NPQ1R-S-0;L1M1R1RQR-S*UG% &, +0 + + +s :A E E" c V^8dQhRRRR/#)rmessagerr r r )r s"r rrs!!T!d!rc \V\4'dVPR4MRp\V\4'dVPR4R8Xd\V\4'd\P\ VPR4;'gR44pVe~\ V4;_uu_4VPR4'dIVPR4'd2VPR 4VR,8XdVPR 4VR &RRR4R #R #\V\4'dVPR4R 8Xdm\V\4'dWVPR4'g@\ \ VPR4;'gR4VPR44R #\V\4'd\VPR4\4'dVPR4R9d\V\4'dB\P\ T;'g/PR4;'gR44MRpVe@\ V4;_uu_4RVR,RVR,R\V4/VR&RRR4MM\V\4'dVPR4R8Xd\P\ VPR4;'gR44pVPR4pVee\V\4'dO\ V4;_uu_4\W#PR44'dVPRR4RRR4\V4# +'giR #;i +'giL/;i +'giLB;i)uRelay host frames to the client while mirroring the server→client request the host has open, so a reconnecting client gets it back through ``open_requests``.paramsNmethodzcompute_host.activityr_rIrunningturn_id_compute_host_turn_id activity_ns_compute_host_activity_nsTeventrApayloadid_compute_host_open_requestzrequest.cancel)Nr) rfrr _sessionsr3 _history_lock_broadcast_global_event_open_request_matchespop write_json)r|r~rrs& r r,r,s'1$&?&?W[[ "TF'4  W[[%:>U%U fd # #mmC <(@(F(FB$GHG""7++ I..6::i3H3H ' ,C DyHY Y?Ezz-?X ;<,7D!!gkk(&;w&F:V\^bKcKcJJ|,, FJJv$6$<$<" =vzz)?TU'4  Z D0A3%G%GGKKX`LaixLxPZ[acgPhPh)--V\\r$6$6|$D$J$J KLnr  w'''$-783DhPTU[P\9^45('  FD ! !fjj&8C * C C #DDc ,V^8dQhRRRRRRRRRR/#) rr2r3rB question_idanswerr:r rr )r s"r rrs1CSsT^cnrc \V4pVe\V^,4'gR#VwrV\4PVRRVRVRV//4pTP R4R 8Xd0\ TR\TP R 4;'gR 44#TP R 4p \T \4'g\ TRR 4#RT 9dz\T R,\4'd T R,M/p \ T\T P R4;'gR4\T P R 4;'gR44#\T P R4\4'dT P R4M/p \T4;_uu_4\Ya4'dzTR,p T P R4R8XgT P R4.8XdTPRR4M1/T R,P R4;'g/CY#/CT R,R&RRR4\Y 4# \dp\ TRRT 24uRp?#Rp?ii;i +'giLC;i)zProxy a batch-clarify lock into the child that owns the request; keeps the parent mirror's locked answers current for reconnect snapshots. None when the request is not host-owned.NlockrBrrz"compute-host clarify lock failed: rAz respond.errorr|z compute-host clarify lock failedresponsez6compute-host clarify lock returned an invalid responseerrorcodeizclarify lock failedresultrstatusexpired remainingr~answers)rr r/rrw_errrr3rfrr-rrr_ok) r2rBrrrr4rackexcrrrrs &&&& r _lock_compute_host_clarifyrs,J7G8DDLCK*,44 &<]KQY[abce wwv/)Cs3779#5#[#[9[\]]wwz"H h % %CWXX(%/0A4%H%H!bCUYYv.66$7UYYy=Q=j=jUj9kll'1(,,x2H$'O'OX\\( #UWF w    5 5;I II I+ c$V^8dQhRRRRRR/#)rrrrnrr ror )r s"r rrs! = = =k =d =rc >\V\4'gR#\V4;_uu_4\W4VP R4eS\ P !\4;_uu_4\VP R4;'g^4VR&RRR4RRR4VP R4p\V\4'd,/\V4CVCVR&\P4VR&R#R# +'giLl;i +'giLw;i)zMirror host-owned session metadata: under turn isolation the host is the only writer of live agent/history state, and UI reads must not build a second agent.N message_count_metadata_message_count session_inford_metadata_mirror_updated_at) rfrrrzrrurvrwr-rdtime)rrninfos&& r #_apply_compute_host_metadata_mirrorrs eT " " w  &w6 99_ % 1$$Y//58?9S9X9XWX5Y120 99^ $D$&K)9')B&Kd&K"#15-.0/ s$AD -(C9 D 9 D D  D c ,V^8dQhRRRRRRRRRR/#) rr2r3r4rrrnr ror )r s"r rr s0,,C,c,D,,RV,rctVR,;_uu_4\W#4RVR&\P4VR&\V4VPRR4RRR4VP R4R8wdVPRR4VP R4R8Xd9\ VP R 4;'gR 4p\ R VR R V 2RR/4\W#4\V4\V4pVP R4'g \ RW4\WV4R# +'giL;i)r=Fr last_activerNrAz turn.errorrKr|zcompute host turn failedzmessage.completer5zError: rrsession_info_emitted session.info) rzr_clear_inflight_turnrrr3_emitr&_release_deferred_active_session_leaserl_drain_queued_prompt)r2r4rrnr|rs&&&& r _on_compute_host_turn_doner s  &w6" !% W% 0$7 ! yyL( *D1 yyL(eii *HH.HI  #''0CXw'WX'7*73 %g .D 99+ , , nc(7+) ! s AD'' D7 c<V^8dQhRRRRRRRRRR R R R R RRRR/ #r1r )r s"r rr"sc%E%E %E%E!%%E-0%E?O%E(%E?I%E"%E.2%Erc aaaa \4p\SSSW4VWgR7p \P4P;o ;V R&V R&SR,;_uu_4S SR&SP RR4RRR4RVVVV 3Rllp \ V4PWR 7SR,;_uu_4R SR &Tf.SR&RRR4\SRRRR /4# +'giLp;i \dp SR,;_uu_4SPR4S 8Xd%SP RR4SP RR4RRR4M +'giM;i\SR R T 24uRp ? #Rp ? ii;i +'giL;i))r7r8r9r;rrBr=rrNc V^8dQhRRRR/#)rdonerr ror )r s"r r4_submit_prompt_to_compute_host..__annotate__1s @ @ @ @rc8<VPR4R8wdpSR,;_uu_4SPR4S8wd RRR4R#SPRR4SPRR4RRR4\SSSV4R#R# +'giL";i)r send_failedr=rNr)rrr)rr2rr4rs&r _complete1_submit_prompt_to_compute_host.._complete1s 88H  .((;;677B)( 3T: 7> ) 'sC$ ? /((sB  $B  B ) on_completerzcompute-host dispatch failed: Trr@r streamingr) rrYuuiduuid4hexrr/ submit_turnrwrrr) r2r4rr5r7r8r9r;rrnrrrs fff&&&&& @r _submit_prompt_to_compute_hostr"sn 3 4C $S#w>V2> cE 8 3T: 7>% $ $ $C!?uEFF G ! sNCC,2E< C) , E97E4;E  E4 E E4.E94E9< F commandrIrwaitTtimeout>@ on_late_ackc4V^8dQhRRRRRRRRRRR R R R /#) rr4r3 route_namerrrrr rfloatr rr )r s"r rrJsD!! ! !+.!>I! ! %!CG!rc \T;'g/4pVPRR4VPRV4\4PWWtVVR7#)rAcontrolr)rrrrr)r setdefaultr/r)r4rrrrrrrns&$$$$$$ r _send_compute_host_controlrJsY B E VY' Y( ' ) 1 1 Eg 2 !!rc$V^8dQhRRRRRR/#)rrrrr-defaultr3r )r s"r rrUs!d#rc VPR4R9d/\Y\VPR4;'gT44#R#)z:``_err`` for a ``control.error``/``error`` ack, else None.rAr|N>r control.error)rrr3)r2rrrs&&&&r _compute_host_ack_errorrUs9 wwv44Cs3779#5#@#@ABB rc V^8dQhRRRR/#)rrrr rr )r s"r rr\sXX[XEXrc^RIHpVeTM \4PR/4p\ V\ 4'g/pV!V4wr4\\\VR,R4\44# \d/pL[i;i)aRPC wait budget for a compute-host compress control: the configured compression ceiling plus slack, capped below the desktop's RPC timeout (a fixed waiter reported false timeouts while the host kept working); slower acks land via the late-ack path. See #97948. )$resolve_context_compression_timeouts compressionrg^@) agent.conversation_compressionr _load_cfgrrwrfrrminrx$_COMPUTE_HOST_COMPRESS_WAIT_CAP_SECS)rrcompression_cfg_idleceilings& r #_compute_host_compress_wait_secondsr\s|T"%/3y{GG WYZ ot , ,9/JNE S4/1UV WW s A44 BBc ,V^8dQhRRRRRRRRRR/#) rr4r3rrrrr ror )r s"r rrns8IIsITII]`IeiIrc\;_uu_4\PV4VJd RRR4R#RRR4\V\4'dVPR4R 9dS\ T;'g/PR4;'gRV R24p\ RVRRV 2/4\VR4R#\W4\ R V\V44\VR R 4R# +'giL;i) a<Adopt a compress ack that arrived after its RPC waiter answered ``pending``: the only place the rotated session_key / history_version / mirror can land and the client's only signal (the same ``session.info`` + ``compacted`` edges the in-process /compress path emits). A late ``control.error`` goes out via ``error``.NrArr|z compute-host z failedzcompression failed: readyr compactedu ✓ Context compression complete>rr) _sessions_lockrrrfrr3r_status_updaterrl)r4rrrr|s&&&$ r %_adopt_late_compute_host_compress_ackrns  == W ,   ,  c4 CGGFO7Q$Qsyybooi0WWmJwi(HIJsG$'5 .#9'BC3 %GH s C++ C; cV^8dQhRR/#)rr ror )r s"r rrs000rc2\\4VRR7R#)zQPublish this module's helpers + handlers onto ``server``, rebound to its globals.)skipN)_)rglobals)servers&r registerr s 6/r)N)NNNN)$__doc__ __future__rrur method_ctxrr _registryr*rr)rrr r/rYrXrdrlrzr,rrrrrrrrrrrrrr r rr rsX#4    ) 0 (-$[ V ($FN R6 8U$!H9K   j(> = ,0%EP!13!LP!!(,!:>!X$I$0r