+ jHjNaRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t ^RI H t ^RIHtHtHtHtHt^RIHt^RIHt^RIHt^R IHt^R IHt^R IHt^R I H!t!^R I"H#t#^RI$H%t%^RI&H't']'d^RI(H)t)]PT!R4t+^t,0R%mt-RRlt.RRlt/R&t0R't1RRlt2RRlt3!RR]44t5!RR]44t6^RI7H8t8^RI9H:t:R t;R!R"lt<!R#R$]8]:4t=R#)(aCPer-turn callback runner (progress/status/voice/run_sync) for the gateway agent turn. ``TurnRunner`` owns the per-turn callbacks ``GatewayRunner._run_agent_inner`` binds. ``gateway.run`` internals are imported lazily inside method bodies (import cycle), so ``patch("gateway.run.X")`` keeps intercepting them at call time. ) annotationsN)suppress)datetime) TYPE_CHECKINGAnyDictListOptionalt)_accepts_keyword)canonicalize_replay_history)Platform)(repair_explicit_computer_use_media_paths)BasePlatformAdapter)ea_default_reason_text) TurnContext)cfg_get)is_truthy_value) GatewayRunnerz gateway.runc V^8dQhRRRR/#) adapter_clstypereturnbool)formats"!_persisted_turn..dsr )compression_unchangedprefix_row_matches)agent.persisted_turn_receiptr8 isinstancedictgetr$rint)agent agent_historyresult compressionsr8statuss&&&& r_persisted_turnrTUs D fd # #%zz-88m$jj22fjj6I6I7z ! :/JD QS` #$f"<0C7SSLG E/ 68KTMS=S@  BBr c]tRt^gtRtRtR#)_NoStreamConsumerzRaised by the delta callback when nothing consumed the text; ``_call_quietly`` turns it into 'not delivered' so the agent's partial-delivery accounting matches what the user saw.rN__name__ __module__ __qualname____firstlineno____doc____static_attributes__rr rrVrVgs]r rVc]tRt^ltRtRtR#)_ExecApprovalDeclinedaEThe connector refused the approval card's destination. Raised (not returned) so it propagates out of `_approval_notify_sync` to `_await_gateway_decision`, whose notify-failure path drops the central approval queue entry and unblocks the waiting tool. A plain return suppressed the text fallback but left that entry pending. rNrWrr rr_r_lsr r_)GatewayTurnProgressMixin)GatewaySessionAgentMixinc ^RIHpV!4pVe\V\4'gR#VR,pVR,P YP R4VP R4VP R4;'gRR R 7VR ,R &R# \ d*pTPRR R \T4R7Rp?R#Rp?ii;i)zA confirmed API model lock settles only on the runtime it named (main's ``_finish_turn_result``): the served runtime rides the usage, a mismatch fails the turn.)api_runtime_lockedNsettingsadapterrouterequested_runtime route_sourceT)rfrgrhconfirmed_runtime_lockusageruntimeF)r?r: completedr;) gateway.session_api_turnrcrKrL_turn_runtime_metadatarM RuntimeErrorupdater+)rOrQcapturedrcapirdexcs&&& r_settle_api_runtime_lockruzs<  C {*VT22:HW'*9~'L'L g.(,,ObBc!n5;;TX(M(Z)$ W RSQTX VVWsA B>B CCCc$V^8dQhRRRRRR/#)rrt Exceptionplatformrrztuple[str, str, bool]r)rs"rrrs'"E"E9"E"EEZ"Er c^RIHp^RIHpHp^RIHpVPPp\W4'dRVP R2VR3#V!VP4'd^RI H pV!\V44VR3#V\P 8Xd RV 2VR3#\#4pR;rTp V e|\%V 4V9dlVP'\%V 44T ;'g\V \(4p T ;'g \W4p V P;'g V P*p KV 'dV 'g\-R 4R R3#\-R 4VR3#) ze``(chat text, failure_reason, retryable)`` for a model/credential resolution failure before the turn.)FailoverReason) AuthErroris_rate_limited_auth_errorRuntimeStoreErroruB⚠️ This session's launch credentials are no longer available (zY), so this message wasn't processed. Start a new session from the CLI to bind them again.F)_gateway_provider_error_replyu⚠️ zgateway.errors.generic_failed host_errorzgateway.errors.no_credentials)agent.error_classifierrzhermes_cli.authr{r|hermes_state_runtimer~auth_permanentvaluerKreason __cause__ gateway.runrr+rLOCALsetidaddOSError __context__r ) rtrxrzr{r|r~rrseenhostauthlinks && r_resolution_failure_replyrs@5E6#2288N#))UUXU_U_T`aaabprwy y!#--00=,SX6MM8>>!55UDD!$D  r$xt3 D00z$022z$2~~11!1!1 D 01<FF , -~u DDr c$]tRt^tRtRtRRltRtR,RltRt RR lt R t ] R R l4t R tR-RRlltRtRRltR.RRlltRRltRRltRtRRltRRltRtRtR tR!tR"R#ltR$tR%R&ltR'R(ltR)t R*t!R+t"R#)/ TurnRunnerz\Per-turn collaborator carrying ``GatewayRunner._run_agent_inner``'s tool-progress callbacks.Nc$V^8dQhRRRRRR/#)rrunnerrctxrrNoner)rs"rrTurnRunner.__annotate__s& I I} I; I4 Ir c hWnW n^RIHpV!V4pVe\ VRR4p\ VRR4\ P 8Xd VPMVPVP4pWdP9d.VPPV4R,pWFV3Vn R#R#R#)r1active_authorityNsourcerxruntime_generation)_runner_ctxgateway.session_authoritiesrr$rrchat_id logical_owner session_idsessionsdb get_session_approval_owner)selfrrr authorityrowner_id generations&&& r__init__TurnRunner.__init__s  @$V,  S(D1F*1&*d*Kx~~*]&44S^^D ---&\\55h?@TU (1Z'H$. !r c dVPe"VPwr4pVPWEW4#R#NF)rpublish_execution)r event_typepayloadrrrs&&& r_publish_executionTurnRunner._publish_executions4    +040D0D -I:..zz[ [r c  VPeJ^RIHpVPwrxp T!YxY\T;'gR4\T;'gR4WE4R#R#)zThe retained tool payload reaches the API observers of this exact admission only; the shared viewer stream keeps its ID-correlated frames.N)publish_api_tool_eventritool)rrnrr+) rrcall_id tool_nameargsrQrrrrs &&&&&& r_publish_api_toolTurnRunner._publish_api_toolsU    + G040D0D -I: "9*#&w}}"#5s9;N;N7OQU _ ,r c  aaaaaaSPoSP'dR#RoSP^,o\\SPRR4RR4pVf^RIHpV!4pSPSPVR4pSP'*;'dVPV4p\SP4;'d)SP'*;'d\4'*pV'g V'Ed ^RIHpSPP!SP"4pV'd\VRR4;'g\\VRR44p T;'dT p SPP%SP"Y(V'dR MR R 7wrT!TSP"P&T SP(SP*eV3R lMRV SP,SP.R 7oSSP0^&V SnS'dSP2'dSMRS3Uu.uF pVfK VNK upoRp\SP"RR4\:P<8HoS'gSP>e RVVVV3RllpRR/RVVVVV3RlllpSVVV3# \4d!p \6P9RT 4Rp ? LRp ? ii;iuupi)NFconfig streaming)StreamingConfig)GatewayStreamConsumerSUPPORTS_MESSAGE_EDITINGTSUPPORTS_NATIVE_STREAMINGfallbackraise)on_missing_cursorc:<SPPR4#) __reset__)r)progress_queueput)rsrrF3TurnRunner._setup_stream_consumer..sS%7%7%;%;N%Kr )rerrmetadataon_new_messageon_before_finalizeinitial_reply_to_idrun_still_currentz$Could not set up stream consumer: %srxc V^8dQhRRRR/#)rtextz Optional[str]rrr)rs"rr7TurnRunner._setup_stream_consumer..__annotate__s . .m . .r cP<SP4'gR#\S4pVe SPRRV/4;'gTpMS'dSPRRR/4SFpVPV4K Ve%V'd\ 4'd \ 4hR#R#)Nz message.deltar)_run_still_currentrron_deltar5rV)r deliveredsinkr delta_sinkslocal_viewer_routers& rstream_delta_cb:TurnRunner._setup_stream_consumer..stream_delta_cbs--// - # $ 7 7&RV X e e\eI'++Ofd^L'DMM$'(#Y:M:O:O ,-- ;P#r already_streamedc$V^8dQhRRRRRR/#)rrr+rrrrr)rs"rrr(s' y ys y yRV yr c<SP4'gR#RpS'dOV'gG\T;'gR4P4'dRVRR/pSPRV4'*pSe<SP R4V'g#SP V4SP R4V'dR#Se.V'dSP 4R#SP V4R#V'g_SP'dK\T;'gR4P4'd SPVSPR4R#R#R#R#)NFrirrzmessage.interimz+interim_assistant_callback scheduling error) rr+striprron_segment_break on_commentary_status_adapter_send_status_text_status_thread_metadata) rrunseenrrrrstream_consumersttss &$ rinterim_assistant_cb?TurnRunner._setup_stream_consumer..interim_assistant_cb(s))++F!*:s4::2?T?T?V?V "4);UC!445FPP d#'MM$'MM$'*6F002OLiLijnLo%#*=*=*=#djjb/BWBWBYBY&&tS-H-HJwxCZ*=%r )NNNF) rmute_notification_replystreaming_tts_consumer_holderr$rgateway.configrresolve_display_setting user_configscheduled_heartbeat enabled_forr"interim_assistant_messages_enabledr5gateway.stream_consumerr_delivery_adapter_forr_build_stream_consumer_configrrrevent_message_idrstream_consumer_holderstream_deltas_enabledrwloggerdebugrrr)r platform_keyscfgrplat_streamingwant_stream_deltaswant_interim_messagesrresupports_incremental_streamconsumer_stream_deltas consumer_cfgpause_typing_before_finalizeerrscrrrrrrrsf& @@@@@r_setup_stream_consumer!TurnRunner._setup_stream_consumersii  & & &* *003wt||Xt%>  !6!6 JI,,<L'< '1C1CL!$!.presentTs )&1>>*--@)$/Dt||DDTYYEUEUW[\_JK  84 H sA<A<<"B"!B")rxr diagnostic)rr gateway.warning_notificationsrrrr _status_liver+r$rrrxr)rrrrrrrr sff @@r_notice_callback_sync TurnRunner._notice_callback_syncFs 3[ 99 , , ,D4E4E4G4G '&%,223 ( (CNN;L,M,M )&1  K K Gdii.>.>.G.G(, (=(=* Vr c naaaaaaaa a a ^RIHoHoSPo\P !4o .o \P !4o SPoSRJ;'d)\SPRR4\P8HoRVVVVVV3RlloRVV V V 3RllpRVVVV V V V3R llpW!3#) u(send, release): background-review messages ("💾 Memory updated") are held until the adapter's post-delivery hook releases them after the main response lands.)_interim_metadata_non_conversational_metadataNrxc V^8dQhRRRR/#rmessager+rrr)rs"rr:TurnRunner._make_bg_review_callbacks..__annotate__os  S T r c l<S'dTS ePS wrpVPPV4pVe*VPPVR\ V4/RR7R#S P 4'dBS P VS!S!SPSPPR74R4R#R#)Nrzreview.summary)r)rxz+background_review_callback scheduling error) rrM event_streampublishr+rrrrrx) r'rr _generationliver#r$r local_viewerownerrs & rdeliver5TurnRunner._make_bg_review_callbacks..deliveros 16;2 { ))--j9#%%--j63w<:P]m-n  ""&&%&B3C^C^ilisisi|i|&}~A#r cV^8dQhRR/#r r)rs"rrr(s ! ! !r c<SP4S;_uu_4\S4pSP4RRR4XF pS!V4K R# +'giL#;irC)rlistclear)queuedr'r0pending pending_lock release_evts rrelease5TurnRunner._make_bg_review_callbacks..releasesE OO g " "s A A# c V^8dQhRRRR/#r&r)rs"rrr(s  # $ r c<S'dSeSwrpVPPV4p\P!4^x,pVe]\P!4V8dCVPP PR4V8Xd\P !R4K`S!V4R#S P4'gR#S P4'gGS ;_uu_4S P4'gS PV4RRR4R#RRR4S!V4R# +'giL;i)Nexecution_generationg?) rrMtime monotonicr* executionsleepris_setappend) r'rrrr-deadliner0r.r/r7r8r9rs & rsend2TurnRunner._make_bg_review_callbacks..sends 1 5:1 z ))--j9>>+c1'DNN,-r c  VPpVPpVPVnVPP VnVPVnVP^,fVP'd!VP;'g VPMRVn VP'd VPMRVnVP e#VP"Vn VP$VnVP&P('gVP e VP*MRVnWAnV'dTMRTn^RIHp VP6V !V4'd VP8M VP:uVnVnRVn VP e.^RI!H"p H#p V PI4eV !WP V4V !V4'd VPJMRTn&VPNVn(W8PRuVn*Vn+VPYW4^RI-H.p V !WP_VP`4VPbR7VPe4wVn3p VPh'dVP`'d~\k\mVPh4RR4e3VPhPoVP`WPpR7M)\kVPhRR4pVeWVP`&VPPIR 4;'g/PIR 4p\sV\t4'd V'dR MR pV'd\wV4Py4MR Vn=VP|Vn?VPVnAVP'd+RVnRVn RVnRVnRVnR VnAWP^&VP e$VP wpppVPVVV4VPW4VPVPuVnHVnI\kVRR4VP^&R#)u\Per-message state (callbacks, reasoning, voice route) — never baked into the cached agent.Nlocal_viewer_turn) api_executionwire_api_observers)arm_surface_turn) voice_turnregister_post_delivery_callback)r_post_delivery_callbacksdisplaymemory_notificationsonoffFtools)Krrr_notification_configrrx_notification_platformprogress_callbacktool_progress_callback_voice_ack_guild_native_slack_task_cardsnative_tool_start_callbackvoice_ack_callbacktool_start_callbacknative_tool_complete_callbacktool_complete_callbackrcombined_tool_start_callbackcombined_tool_complete_callback _hooks_ref loaded_hooks_step_callback_sync step_callbackstream_delta_callbackinterim_assistant_callbackgateway.run_turn_progressrZ_status_callback_sync_local_notice_callback_syncr status_callbacknotice_callbackreasoning_callbackrnr[r\rM!_local_notice_clear_callback_syncnotice_clear_callback_event_callback_syncevent_callback _service_tierreasoning_config service_tierrVgateway.session_surfacer]#_consume_pending_turn_sidecar_notes session_keyr^rKbackground_review_callbackrr$rr_run_generationrKrr+lowerrb_clarify_callback_syncclarify_callback_thinking_enabledthinking_progressr agent_holder adopt_agent_attach_session_title_callbackprocess_task_idprocess_baseline_gateway_turn_process_task_id_gateway_turn_process_baseline tools_holder)rrOrSrrrrrrrZr[r\r] bg_releasepdc mem_notifrrrs&&&&&&& r_wire_turn_agent_callbacks%TurnRunner._wire_turn_agent_callbackssii%(__"'*zz':':$(+'<'<$ $$Q'3s7S7S7S + + E Es/E/EZ^ !MPLhLhLhs'H'Hnr$    +(,(I(IE %+/+O+OE (:=..:U:U:UY]YmYmYyc55AE&5#CX+?^b(?7:7P7P0A$0G0GD , ,TMgMg 5u4#'    + R  "."5*>*>@UVPabfPgPgd&L&Lmq#"775EG[G[2 2 **5=<  J J3?? [hkhvhvw7;7U7U7W4(*    3???tC//02SUYZf##CCCOOU_l~l~Cc113MtT?+5(__((399r>>?UV i & & )uI?HS^%9%9%;d"!%! ++E7UXTgTgili}i}Q+U-Q%eWd;r c(V^8dQhRRRRRRRR/#)rrr+ placeholderz str | Nonereopenrrr)rs"rrrs*Cjaervr c VP4pV'd\VRR4'gR#RpVPW!VR7p\V\4'dVwre\ VR4'gR#VP ^ R7pV'g\PRV4\V4# \\3d+pTeRTR &\PR Y4Rp?R#Rp?ii;i) aNative-streaming platforms (e.g. WeCom): an interrupting interaction (approval or clarify prompt) must finalize the current stream first, or post-interaction output keeps updating the OLD bubble above the prompt. Runs on the agent thread; the consumer serializes via its queue._use_native_streamingFTN)rrrQtimeoutuX%s boundary failed to close stream properly — prompt may still appear in typing bubble cancelledz#%s boundary timed out or failed: %s) _stream_consumerr$close_for_approval_promptrKtuplehasattrrQrwarningr TimeoutErrorrw) rrrrrcancelled_flagboundaryokrs &&&& r_close_native_stream_boundary(TurnRunner._close_native_stream_boundarys " " $wr#:EBB 33KW]3^H(E**+3(8X..,B?@F8Oi( ).2{+ NN@& N  s#?B-2B- B--C(>C##C(c "VPPP!R/VBGRjxL pVPeLVP'd:TPwrEp^RIHpVPWVVVPVR4R7V#L_5i)Nlocal_viewer_eventsclarify timeout_sr) rr send_clarifyrsuccessgatewayrregister_clarifyprompt_timeout_s)rentrykwargsrQrrrrs&&, r_send_shared_clarifyTurnRunner._send_shared_clarify syy00==GGG    +040D0D -I: 3  & &zu1D1U1UVZ\e1f ' h Hs*BB #BSP<wpppTP>T,P@PCTT4T'gb\/\ESP4RR4p\3T4'd-SP9T!SPT \G44R4TT3#T'dPSP14pTeTPI4SPPKSP4TT3#TT3# +'giEL;i \*d\4P7RR R7ELyi;i \*d\4P7RR R7Li;i \*d\4P7RR R7TT3#i;i)zOne card: register, send, wait, then retire it (no answer) or re-arm (answer). Returns ``(response, answered)``; the caller decides what "no answer" means.)r_clarify_send_then_waittext_fallback_coro)clarify_gatewayNFri:N N)rrr clarify_idrrcZ<S!SP3/SBpVfR#SPVR4#)zWSchedule the plain-text prompt when the native card cannot render; None = no such path.Nz(Clarify text fallback failed to schedule)rr)cororr send_kwargsrs r_text_fallback8TurnRunner._ask_clarify_question.._text_fallbackes3%c&9&9I[ID<4 mT^^DBl-m mr )rrrrrClarifyz)gateway.clarify.native_stream_placeholderT)rflush_pending_syncg@rz2Stream-consumer flush before clarify prompt failedrzClarify send failed to schedule)rr clarify_modrretire_clarify_cardz&Clarify card retire failed to schedulez/request_reopen_seed after clarify answer failedz2resume_typing_for_chat after clarify answer failed)&rrrrreruuidrrruuid4hexr4rL_status_chat_idrregisterrrr rrwpause_typing_for_chatr$rr%rrrrrrcontrolssnapshotrr-request_reopen_seedresume_typing_for_chat)rrrrrrrrrrrrrflushfutresponserrrrretirerrrrsf&&&& @@@rr TurnRunner._ask_clarify_questionQs Q Q8ii"""*50 0oo++ ZZ\%%c* #*$w-''(Xb#c.I.I  n n$$!Xl+%  **9a8c6dmq*ri    5 5c6I6I J! --/1EtL ^c"nn  % %e ;{ ; - 5 K#%(    +040D0D -Iz:   z * 3 3 < "!!&&(B~c**, b##::3;N;NO!!x!!c!  ^ LLMX\L ] ^D!cLL!R]aLbc b Q\` a!! bsB&J)J=+K&<%L) J: ="K#"K#&"L  L "L65L6c V^8dQhRRRR/#r approval_datarLrrr)rs"rrrs j j4 jD jr c  $VPe!VPwr#pVPW44VPV4VPeC^RIHpXP XXVP PVVPVR4R7R#R#)Nrapprovalr) rcheck_approval_generation_render_approval_syncrrregister_approvalrrr)rrrrrrs&& r_approval_notify_sync TurnRunner._approval_notify_syncs    +040D0D -I:  / / G ""=1    + 3  ' ' J @U@UWd2E2V2VW[]g2h ( j ,r c V^8dQhRRRR/#rr)rs"rrrs"_C_C4_CD_Cr c ^RIHpHpHpHp^RIHpVPpVPpVPVP4VPR4V!VPRR44p VPR4;'g \4p RU U u/uFwrWPW4bK p p p \\V44'dTP!VP"!R RVPRT R VP$;'gRRV R VP&/V BR 4pVf \)R 4hV!V^R7pVR8Xd)V!WV \+VP-^R7RR 4R7R #VR8Xd\.P1R4R #VR8Xd!\.P1R4\3R4h\.P1R4V!W\+VRR43/V Bp/VP&;'g/CRR/CpVP!VP7VPVV!V4R7R4pVe VP-^R7V!WV R R7R #R #uup p i \2dh\4d!p\.P1RT4R p?LR p?ii;i \4d"p\.P9RT4R p?R #R p?ii;i)!zSend the approval request from the agent thread: the adapter's interactive button approvals (``send_exec_approval``) when available, else plain text with ``/approve`` steps.)_approval_send_outcome_format_exec_approval_fallbackr#_redact_approval_command)register_timeout_noticeApprovalcommandri descriptionTrrrz#send_exec_approval scheduling errorNz$send_exec_approval: loop unavailablersent message_id)rcard_message_id ambiguousu{Button-based approval send timed out — treating as possibly-delivered (no re-send; the prompt stays armed for a late tap)declineduButton-based approval DECLINED by the connector's egress guard — not falling back to text (the destination is not approved for this connection)zGexec approval undeliverable: connector egress declined this destinationzHButton-based approval failed (send returned error), falling back to textz6Button-based approval failed, falling back to text: %styped_command_prefix/is_approval_prompt)rz#Approval text-send scheduling errorz#Failed to send approval request: %s))allow_permanentT) allow_sessionT) smart_deniedFr)rrrr#r'gateway.run_turn_runner_approval_settlerrrrrrrMrr(rrr#rrrpr$rQrrr_rwrFr;)rrrrr#rrrrecmddesckdflagsrremsgrs&& rr TurnRunner._render_approval_syncs D DSii%% %%c&9&9: **:6&}'8'8B'GH  /KK3I3K9FG9F%%a++9FG )$w- 8 8< \nn.. # 3 3=@NQooNcNcac$(363N3NRW: ;&'MNN0bAf$,S(/ 1 0E|UY(Z\k)NN6 j(NNK0+ij-SI_ad8eoino C[366<<"Z?SUYZH.. S00#@QRZ@[ \_DC 2 &(SZ^_ UGt)  \WYZ[[ \" C LL> B B CsVI9I A I-I w"GG G 1M KK(:(:NijmjyjyNz1 -   75,#E#W3M75RegkClmHdll,EtLGACC$,,>,4;KKQR4SVW4WW1&,0P&PfllV\VdVdMOOS%7X!AAeGI !>tyy?O?OPRfhlmnnr c .^RIHpHpHpHpHpVP pVPp^RIH p V !VP4PR4p V eVeTM VPp T pWn VPR4V!4p V!V!VP4V R7p RpVP'dZ\!\"4;_uu_4VP$P&P(PVP4pRRR4VRJ;'d\+VRR4pV'd\+VR R4;'gR MRpT;'dV!\+VR R4V R7pV'd=V 'g V'd-V!VVPVP-4R 7wVn pMQV'dJVR,PR 4R8Xd-V 'd%VPpRVP,Vn VPR4V eX p\/VP\04'dGVPP34'g'V'dV!VRVP-4R 7Vn WP43# +'giEL;i)zPrepend recovery/notice guidance to ``ctx.message``. Returns (persist_user_message_override, persist_user_timestamp_override): real user text is kept separate from API-only recovery guidance so stale guidance never replays as user text. )_auto_continue_freshness_window_is_fresh_gateway_interruption_last_transcript_timestamp_prepare_resume_pending_messagebuild_resume_recovery_notecli_turnapi_textN_pending_model_notes) window_secsresume_pendingF resume_reasonrestart_timeoutlast_resume_marked_at) interactiver1rz[System note: A new message has arrived. The conversation history contains pending tool outputs from an interrupted turn. IGNORE those pending results. Address the user's NEW message below FIRST. Do NOT re-execute old tool calls from the history.] _pending_skills_reload_notesrir9)rrSrTrUrVrWrpersist_user_messagerrYinbound_message_idrMr'rKr/rrrwr session_store_entriesr$rPrKr+rpersist_user_timestamp)rrPrSrTrUrVrWrpersist_overriderYrZ clean_textwindowinterruption_is_freshrr]r^ mark_is_freshs&& r_prepare_turn_message TurnRunner._prepare_turn_messageZs+   ii*-*B*B5C22377 C  .>-I)s{{J) "K ""#9: 12 >?YZ]ZeZe?ftz { ???)$$ 22;;??P%d*VVwu>NPU/VXf>SSBSlp '  +I E2D 9v,  4 ,Ks{{8U8U8W- )CK)}R044V<FK`"{{ W++  K ""#AB  )  ckk3 ' ' 0A0A0C0C4]BTXTqTqTstCK!;!;;;A%$$s :J J c VPp^RIHpVP4pVe/\ VPR4\ 4'd VR,#VP PVP4pV'g VP#^RI H pV!VPV4wrgV'd!\PR\V4V4\;QJdRV4F 'gK RM RM !RV44'dV#VP# \ d,p\PR T4Rp?TP#Rp?ii;i) zWrap the user turn as an OpenAI-style multimodal content list when _prepare_inbound_message_text buffered image paths; consume-and-clear so later turns on the same runner never re-attach stale images. Falls back to plain text when nothing is readable.r.Nr4)build_native_content_partsz:Native image attachment: skipped %d unreadable path(s): %sc3H"TFqPR4R8HxK R#5i)r image_urlN)rM.0ps& r 7TurnRunner._native_image_run_message..s?A55=K/s "TFz8Native image attachment failed, falling back to text: %s)rrnr[rMrKr4r#_consume_pending_native_image_pathsrr'agent.image_routingrprrranyrw) rrr[rs native_imgsrppartsskippedrts & r_native_image_run_message$TurnRunner._native_image_run_messagesii:! ?z#'')* !llFFsW ;;  \ F7 [QNE[]`ah]ikrss??sss???? @{{ \ NNUWZ [ [{{ \s+A DD1D D E&E  Ec  ^RIHp^RIHpHp^RIHp Hp VPp V P;'gRp V !V 4p V!WP4V!VP4V4pRVRV P/p^RI HpVP4pVe@VPR 4'd)\!VP"R 4'd VR ,VR &\!VP"R 4'd^R IHpVeVPR 4MyVP4;'gcR V P(P*;'gRR V P(P,;'gRR\/\1V P(RR44/VR &V P2eV P2VR&VeWOR&MV'dV P4VR&V P6'dV P6VR&V P8'dV P8VR&V P:eV P:VR&^RIHpV!WP@V4pVe"\!VP"R4'dVVR&VeW_R&V PBe\EV PB4VR&^RI#H$p^RI%H&pVP4p\1VR^4;'g^\1VR^4;'g^3pT!YPNV P;'gRR7;_uu_4VP"!V3/VBpRRR4Ve~\Q^\1VR^4;'g^V^,, 4p\Q^\1VR^4;'g^V^,, 4pRVRVR VV,/VR!&\SVXV4XV!V 4\U\V4;_uu_4^R"I,H-pV!V 4RRR4V !V 4# +'giL;i +'giL,;i T!T 4\U\V4;_uu_4^R"I,H-pT!T 4RRR4M +'giM;iT !T 4i;i)#uRun the turn with the per-session gateway approval callback registered: dangerous-command approval blocks the agent thread (mirrors CLI input()); the callback bridges sync→async.)+_wrap_current_message_with_observed_context)register_gateway_notifyunregister_gateway_notify)reset_current_session_keyset_current_session_keyriconversation_historytask_idr.Nrelay_metadata turn_author)admission_authorrnameis_botFtitle_user_messagercpersist_user_display_kindpersist_user_display_metadata moa_config)arm_onboarding_turnpreludergpersist_user_platform_id)notification_turnexecution_resultsession_prompt_tokenssession_completion_tokens)mutedr input_tokens output_tokens total_tokensrk) clear_session).rrtools.approvalrrtools.approval_contextrrrrr r~rrnr[rMr run_conversationgateway.session_ingressrruser_id user_namerr$rr'rrrgateway.session_onboardingrrrdr+agent.notification_presentationrgateway.session_resultsrrmaxrurrwrr)rrOrPr>persist_user_message_overridepersist_user_timestamp_overriderrrrrrrtoken api_messagerr[rsrrrrrrrrDrQincomingoutgoingrs&&&&&& r_run_conversation_with_approval*TurnRunner._run_conversation_with_approvals LU]iioo++ ' 4 -G-GH: -EdFdFdFfh~K,mYWF >##%C377+;#<#b9c/e}%%%1/2/E/E+,,81N-.'14-.,,,7:6S6S23000:=:[:[67~~)'*~~|$ F)%1E1E}UG"'78N8NPY'Z'Z$+y!.:3R/0%%1589O9O5P12 I @'++-He%N3OQT(U(U'O'(&**Z*DUXYfUg(F# $ &!  "  ! vt $ $VZZ-A-A&**UbJcJc ;'u4,-B"c""rxxzzbIo$&!  $  " " $  %  " "#4 5 %  " " $ %sEE76E7cV^8dQhRR/#r r)rs"rrrshh4hr c VPpVPPPP VR7pV'dsVP R4'dZ\ VR,4VPn\PRVPPVPV4R#R#R# \d\PRRR7R#i;i)zTelegram DM whose source.thread_id was lost in the session split (synthetic/recovered event): restore it from the binding so _thread_metadata_for_source yields the right message_thread_id instead of the General thread (non-fatal).)r thread_iduGRestored source.thread_id=%s from binding after session split %s → %sz>[k l((1155cooFEI#*5,#E --//KK=..30B0B &9 $I%7KK/..3@P (8$((..0((EEFVXgXgilisist $IjjCT2h6G6GGGTWYdfjLkosLs[$7?FDVDVDb@@AQR33CG^3_5../334DEE  1 12B J),>SEW!V;;r cV^8dQhRR/#r*r)rs"rrrdsCr c  ^VPp^RIHpVP4pVe#VR,PR4;'gR#VP;'gRpVP ;'gRP 4VPPVPPVPP;'gR\VPRR4\VPRR4R73F+pV'gK VR ,V,P 4pK- V#) zPlatform context + YAML channel_prompts hint + channel_overrides system_prompt (or global ephemeral) + the gateway ephemeral prompt.r.Nrdephemeral_system_promptrirparent_chat_id)r parent_idrH) rrnr[rMcontext_promptr5rr_get_system_prompt_for_channelrrxrr$)rrr[rscombinedextras& r_combined_ephemeral_prompt%TurnRunner._combined_ephemeral_promptdsii:! ?z?&&'@AGGR G%%++    % %2 , , . LL 7 7 ##SZZ%7%7%=%=2QTQ[Q[]hjnIo!#**.>E 8  Eu$v-5<<> r c V^8dQhRRRR/#)rr?r+rr)rs"rrrxs>>c>jm>r c ^RIHpRV9dV#V!VPR.4\V4VR7wrgV'gV#V'dR.M.\ \ P V44,pVR,RPV4,#)ujAppend MEDIA: tags from tool results (e.g. TTS) that the model's final text omits, so extract_media() delivers each file once. Scoped to THIS turn (slice at len(agent_history)) so a stale MEDIA: path from an earlier turn never rides a later reply; the history-path dedup is the secondary guard — and the sole one when mid-run compression shrank the list.)_collect_auto_append_media_tagszMEDIA:r=)rhistory_media_pathsz[[audio_as_voice]]r)rrrMrr4rLfromkeysjoin) rr?rQrPrr media_tagshas_voice_directive unique_tagss &&&&& r_append_auto_media_tags"TurnRunner._append_auto_media_tagsxs @ ~ %! !+J JJz2 &s=7I_r+ ' ! !1D,-"PTUYUbUbcmUnPoo $tyy'===r c  ^RIHp^RIHpHpHpHp^RIHp^RI H p^RI H pV!VPVPP4p V!4;_uu_4p V P!V!W!VP4R74V P!V!44V!WPP"4VP%4p ^R IHp V P-4pVeMVP.P1R R4pV'd$/V CVCV P-R 4'dR R /M/CMT VR &V uuRRR4# Td%p T P&R8wdhT!T 4p Rp ? LRp ? ii;i +'giR#;i)r1) ExitStack)bind_turn_workspacepolicy_for_source policy_scopeworkspace_unavailable_result)api_policy_scoperr})rworkspace_unavailableNr_cli_result_fieldsresponse_previewedTrQ) contextlibrgateway.session_policyrrrrrnrrrrr~rrr enter_contextr_run_sync_scopedrrrrM__dict__rR)rrrrrrrrr~policyscoperQrtrrr cli_fieldss& rrun_syncTurnRunner.run_syncsD(}}=@:"4<<1A1AB [[E 1##LCSTXT`T`Ca$bc ##$4$67#FII,@,@A..0 @'++-H#!]]../CTJ "{vzzPVPZPZ[oPpPp1Et0Lvxz'-"+[% >::!885f= >[[sCE'(D9A?E'E'! E'9E$EE'E$$E'' E8 c aaCaDaEaFaG^RIHpHpHpSPpSP p^RIHpV!WTP4pV'd=VP'd+VP'd^RI H pV!VP4V'd VPMJVPP\P8XdRMVPPP p SP#4p V'd6VP$'d$RP'RWP$344p V'd VP(MV!4p ^RIHp V !4p V e'V P.p \1V P24VnVP5VPVPVP6R 7wr\9VR R4pRVn^R IHpV!W4wrV'd8VP@'d&V'g^R I!H"pVPGV!V44p^R I$H%pV!SW~V4wr\LPORYPQR4VP;'gR4^R I!H"p^RI/H0pT'dT!T!T4T4M TPbpT'dTPeYTP4M'TPgTPTPTR7p^RI$H4pT!ST4pT'dTPkYTP4M&TPmTPTPR 7Tn7^R!IH8pTPQ4pTeZ^R"I9H:pH;p HRT3PQR.4RT3PQR^4RT3PQRR4R:T3PQR:4R;T3PQR;4RT3PQR>4RT3PQR4/ \U:u/uFp:T:T39gK T:T3T:,bK up:CR?T3PQR?R4R@T3PQR@R4RTP^,;'g.RAT>RBT.s,h8b1fgQQ8bs  )current_room_execution_policyN)rrr_pre_agent_fallback_notice)prepare_api_runtimer)one_turn_routez3run_agent resolved: model=%s provider=%s session=%sproviderriz*Model resolution failed for session %s: %sTr) stamp_failurer?r= api_callsrer:rmFr;)session_routing)rrmodel)one_turn_reasoning)rrr.)_request_reasoning_config_request_service_tier_REQUEST_OPTION_MISSINGrd model_optionsrYr)TURN_BASE_ATTRsession_output_tokensr@rA)run_classic_cli_turn)secret_prompt_scope)sudo_prompt_scopec.<SPSSSSS4#rC)r)rOrPr> persist_msg persist_tsrsrrF-TurnRunner._run_sync_scoped..$sD<`<`=*@+z=[r ) publish_usage)record)publish_settled_info_codex_sessionlast_prompt_tokensrrrrrcontext_lengthfailure_reason usage_limitpartialr9interrupt_messagecompression_exhaustedcompression_deferredrrr _compressedcurrent_turn_user_idxpersisted_turnr_interim_text_was_deliveredr. billing_blockr) history_lenzgateway.shared.warn_passthrough)r;last_reasoningresponse_transformedresponse_reusedagent_persisted)mrrrrrrrrryolortools.approval_yolorrxrrrr skills_promptr max_turns$gateway.hosted_room_execution_policyr max_iterationsr4enabled_toolsets_resolve_session_agent_runtimerr$r rnr rrr current_modelrr rrrMrwragent.turn_failure_copyrrr+ gateway.session_worker_constructr_provider_routingcurrent_reasoning_config!_resolve_session_reasoning_configrcurrent_service_tier_resolve_session_service_tierrr[gateway.platforms.api_serverrrr_reasoning_configr_resolve_turn_agent_configr'_resolve_turn_agent_pending_fallback_noticerryrZrrrwiregateway.session_usagersetattrrNrCrmrgateway.session_secret_promptrgateway.session_sudo_promptrrestorer gateway.session_local_inventoryr"rTrr5_close_codex_session_codex_session_promptrrrr@_LEDGER_PASSTHROUGH_KEYSr_FAILURE_DESCRIPTOR_KEYSrrr%rKrLrr r)Hrrrrrrrrrrcombined_ephemeralr;r roomrruntime_kwargspending_fallback_noticer rr rtrrr retryablerprrrr[rsrrrrequested_reasoningtierrr interim_cb want_interimrSr<rZ local_sinksrrrrRrrrrQr r"r.r?has_compcomprrkreffective_session_idrcommon previewed viewer_meta was_deliveredrOrPr>rrsHf @@@@@rrTurnRunner._run_sync_scopeds  {zii ="6::6 fkkkcooo = coo .*0v @S@SW_WeWe@euknkukuk~k~lElE !<<> f***!',h9KMaMa8b,h!h -3))9P9RV,.  !00N#'(=(=#>C  m$*$I$IzzsCOO%J% !E '.f6RTX&Y #04F - D$7$N !E&,,,/FI,,-=f-EF ?$24$W !E LLE))*5s7L7L"  ADBH_-f5v >fNfNfX^F;;FOOT  4 4CJJTWTcTckp 4 q ?-d4DEX^ ; ;FOO T  0 0 PSP_P_ 0 ` :! ? ~ ~";C O3wu>UWX/Y/^/^]^+_ ` 2IMI`I`afh{I| FM13F&*&@&@&O #K"752F#MObdhiL E I E"4//1DT51Q1Q-d5[5[\2R/&7#++E;??dE$7P$T51( v|T $$V]OL  WU4Dd%K%W  & & (*.E ' $45  #;GG752F#G+3u'' H'$0Da"HZ[ (GE+BAFXY xWU,GK]^ eWUGT2 Ez48t 8wt-=qAFFQYZ  0HY/G3RX=#sFJJsO#/GY  DHC_C_`mCn@0.  :r2KKYZA[ fjj513CVZZP`Ea 6::m4 vzz)U3[&**[BY 6::mU;=PRXR\R\]pRq VZZ( ,DU+CCsf}sF3K+CU  $VZZ0G%O "FJJ/Eu$M S%%a(..B n.BDVXdfz );>RVYVdVd>d t$jl $NehnMn'0G)HItv% &' (6D .1) ,JJ3U;   "#E+H$OMYGG8M+B,F,FtNG[,F,F`mn|`}BFaFHIAKFJJWfLgimAnAnOVO%<=tv6@ 9@UWZ5[5[`fgp`q`qIvi01wyK Q>QSabN!`f`j`jkr`s`s#DFSZO!\y{&$n8>BM$fjj1A&B()*D K[@\ `f ju ) "FJJ/Eu$M vzz*;UC vzz*;TB  k m NNGI^I^\^`cnrN s =&?SZZEXEX&Y #D&) "2D*b+WXZace"*D+ugsSVx"YZ`bkm m ml2R1Q1Q///&7#++E;??dE$7P$T51 'DZVsA1i6i>A)iA%l?lk- $l,l= m m2 mm k*(A7k%k*%k*- k> 8 l l l?m)rrrrCr)T)#rXrYrZr[r\rrrrrr rK staticmethodrVrrrrrr rrCrKrPrmr~rrrrrrrrr]rr rrrsf O I _k]`V:<| ? ?Q:No Slack thread target(slack task_card requires a thread anchorKslack task_card requires a thread anchor (Slack streams are thread replies)) estimated_cost_usd cost_status cost_sourcecache_read_tokenscache_write_tokensreasoning_tokensrr turn_exit_reasonr) free_tierfailure_retryablefailure_resets_atusage_window_message)>r\ __future__rasyncio dataclassesjsonloggingqueuererHr?rrrtypingrrrrr agent.i18nr agent.interrupt_compatr agent.replay_cleanupr rrgateway.media_repairrgateway.platforms.baser$gateway.platforms.base_exec_approvalrgateway.turn_contextrhermes_cli.configrutilsrrr getLoggerrr;_CARD_DESTINATION_REFUSALSr(r-rTrUr5rTrprVr_ryr`gateway.session_executionrarurrrr rrs#   ;;3<#I6G,%!)   = )$% H( k* B$] ] L?> W "EJ[ )+C[ r