PL jrdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZmZmZddlmZddlmZddlmZddlmZdd lmZmZdd lmZdd lmZdd l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlm?Z?m@Z@ddlAmBZCddlDmEZEddlFmGZGddlHmIZIddlJmKZKmLZLejMeNZOdZP d(d)d&ZQd'gZRdS)*uThe agent conversation loop — extracted from ``run_agent.AIAgent``. This is the biggest single chunk pulled out of ``run_agent.py``: the roughly 3,900-line :func:`run_conversation` body that drives one user turn through the agent (model call, tool dispatch, retries, fallbacks, compression, post-turn hooks, background memory/skill review nudges). The function takes the parent ``AIAgent`` instance as its first argument (``agent``) and accesses its state via attribute lookup. ``_ra().AIAgent.run_conversation`` is now a thin forwarder. Symbols that production code or tests patch on ``run_agent`` directly (``handle_function_call``, ``_set_interrupt``, ``OpenAI``, ...) are resolved through :func:`_ra` so those patches keep working. ) annotationsN)AnyDictListOptional_is_oauth_tokenset_runtime_main)_summarize_user_message_for_log) KawaiiSpinner)FailoverReasonclassify_api_error)IterationBudget)build_memory_context_block) _repair_tool_call_arguments_sanitize_messages_non_ascii_sanitize_messages_surrogates_sanitize_structure_non_ascii_sanitize_structure_surrogates_sanitize_surrogates_sanitize_tools_non_ascii_strip_images_from_messages_strip_non_ascii)estimate_messages_tokens_roughestimate_request_tokens_roughget_next_probe_tier(parse_available_output_tokens_from_errorparse_context_limit_from_errorsave_context_length)clear_nous_rate_limitis_genuine_nous_rate_limitnous_rate_limit_remainingrecord_nous_rate_limit)_install_safe_stdio)apply_anthropic_cache_control)jittered_backoff)has_incomplete_scratchpad)estimate_usage_costnormalize_usagedisplay_hermes_homeset_session_contextstrip_pattern_and_formatset_current_write_origin)base_url_host_matchesenv_var_enabledcddl}|S)zLazy reference to ``run_agent`` so callers can patch ``run_agent.handle_function_call`` / ``run_agent._set_interrupt`` / ``run_agent.OpenAI`` and have those patches reach this code path. rN run_agentr6s ;/home/kuhnn/.hermes/hermes-agent/agent/conversation_loop.py_rar9Ls   user_messagestrsystem_messageconversation_historyList[Dict[str, Any]]task_idstream_callbackOptional[callable]persist_user_message Optional[str]returnDict[str, Any]cEFGHIJKt ddlm}|t ddpdt ddpdn#t $rYnwxYwddlm}|jddl m } | t dd  t|trt|}t|trt|}|_d _|_|ptt%j} | _d_d_d_d_d_d_d _d _d _d _d_j !d _"d _#j$d kr; %r&dn#t $rYnwxYwj'r(d _'tSj*_+tY|} t[| dkr | d ddzn| } | .dd} t^0djpdj1j2pdj3pdt[|pg| |rti|ng} |r.j56s7||rVj8dkrKtsd|D}|dkr,|_8j:dkrj;dkr|j:z_;xj8dz c_8t dd }||<t dd }||<||n|}d }j:dkr9dj=vr0j>r)xj;dz c_;j;j:kr d }d_;d|d}| ?|t[| dz }|_j@sGtY|}Ad|d dt[|dkrdnddjB=d }|rQjCrJ jCDj}|r|Ed pd }n#t $rYnwxYw|r|_BnމF|_B dd!lGmH}|d"jj1t d#d pd$n2#t $r%}t^Id%|Yd }~nd }~wwxYwjCrY jCJjjBn2#t $r%}t^Kd&|Yd }~nd }~wwxYwjB}jLrct[| jMjNjMjOzdzkr5t| |pdjQpd '}|jMjRkr t^0d(|d)jMjRd)j1jMjSd)&d*|d)d+jMjRd)d,td-D]}t[| }U| ||| .\} }t[| |krnSd }d_d_d _d _d _t| |pdjQpd '}|jMjRkrnd} dd!lGmH}|d/j|ti| t| j1t d#d pdt d0d pd1} g}!| D]}"t|"tr>|"Ed2r)|!?t|"d2Ut|"tr)|"Xr|!?|"|!rd3Y|!}n2#t $r%}t^Id4|Yd }~nd }~wwxYwd}#d }$d }%d}&d}'d}(g})d}*d}+i_Ztj\j]_^t`d j^jar/t`d j^d _bnd _cd _bjdrK t|tr|nd},jdej8|,n#t $rYnwxYwd}-jdrG t|tr|nd}.jdf|.pd}-n#t $rYnwxYwj$d5krg||| | |6S|#j*krj+jhdksjibrjjkjar"d }%d7}+j@sAd8bnd|#dz }#|#_lmd9|#jird _inTj+ns;d:}+j@s0Ad;j+jod<j+jpd=an݉jq" g}/tt| D]\}0}1|1Ed>d?kr|1Ed@rt[| |0z }2iG| |2d D]N}3|3Ed>dAkrn2|3EdB}4|4r|3EdCdG|4<OGfdD|1d@D}/nq|#|/n3#t $r&}5t^KdE|#|5Yd }5~5nd }5~5wwxYwjtdkrdFj=vrxjudz c_uv}6|6rid }7tt[| dz dGdGD]}8| |8}9t|9tr|9Ed>dAkrdH|6}:|9EdCd};t|;tr |;|:z|9dC<nB |;rti|;ng}<|{| |>jO}?|?dkr|>0dP|?jpdQ|| }@|@dkr|>0dR|@jpdQg}At| D]a\}B}C|C}}D|B|kr|CEd>dkrg}E|-r&t|-}F|Fr|E?|F|r|E?||ErI|DEdCd}Gt|Gtr|Gd3zd3Y|Ez|DdC<|C|DdS|Dvr|DdSdT|Dvr|DdT|DdUd r|D|A?|Dc|pd}Hjr|Hd3zjzX}H|Hr dV|Hdg|Az}Ajrj|Ar!|AdEd>dVkrdnd}ItjD]0\}B}J|A|I|Bz|J}1jrt|AjjW}A|A}A|A}A|AD]G}Kt|KEdCtr|KdCX|KdC<H|AD]}K|KEd@}L|Lsg}M|LD]ؐJtJtrdXJvr tjJdXdY}NiJdXiJdXdYtj|NdZd [iiJnS#t $rFtJdXdYJdXEd\d]JdXdY<YnwxYw|M?J|M|Kd@<t!|Atsd^|AD}Ot#|A}Pd Kj@sdjd_|#d<j*djd`t[|Ada|Pd)db|Od)dcjddjQrt[jQndnt)jt-j}Qt)jt-j}Rjr|Qd|Rdnss_rKt)jgde}St-|Qd|Rd|SjfKKjrtjKdgj1dht[| dijQrt[jQndtjKdj| r| dGd>ndtjKdk|Pd)dlt?j}Td}Uj}Vd }Wd-}Xd }Yd }Zd }[d }\d }]d }^d }_d }`d }ad }bd }cdm}dd }ed }f|U|Vk;rj2dnkr ddolm}gm}h|g}i|i|idkrdp|h|idq}jjdr|jdsd t&dr|jrd}Ud}*d }W| |dr|jdu| |#d d |jdvSn#tL$rYnt $rYnwxYw |A}fjrtU|fj$dwkr)|fd x}f dd!lGmH}|fEdy}kt|kths|fEdz}kt|kths|A}k| did|| d}jpdd~|dti| d#j3pddj1dj2djdj$d|#dt|kthrti|kngdt[|Adt[jQpgd|Pd|Odjn#t $rYnwxYwt_dr|fdKfd}ld }mt dd rd }mnj2dksvtjpdds;tjpddrd }mn;s'ddlm}ntt dd |nrd }m|mr|f|l}en|f}et?j|Tz }oKrKdd Kjrdj@s!jd|oddjrG|ert |eddnd}ptjKd|pdtq|edr|ejndd }qg}rj$dwkr}s|s|es|ed }q|r?dn(tt |eddpdX}t|tdvrt |edd }ut|utr|uEdn|urt|und|td}vtjId|t|vd }q|r?d|td|vnFt |edd }wt|wtr|wXnd}x|xr*t^Kdt[|xnt |edd }yt |edd }zt^Id|y|zt |edd dj$dj2d }q|r?dnfj$d kr[}{|{|es0d }q|e|r?dn|r?dnj$dkrY}||||es/d }q|e|r?dn|r?dn}}|}|essd }q|e|r?dnYtq|eds|r?dn2|ej|r?dn|r?d|qryKrKdd Kjrd|Udz }Ujt[jkr&drd}Ud}*d }WgdHd}~|erptq|edr_|ejrXt|ejHtq|ejdr,|ejjr |ejjEdd}~n/|er-tq|edr|ejrt|ejH|~dkr$|er"tq|edr|ej1r d|ej1}~|~dkrL|erJdt|eD}jrtjKd|d }|ertq|edr|ejryt |ejdd }|4t|ejtr|ejEd}|+ t|}n#ttf$rYnwxYw|dkrd|odd}na|dkrd|odd}nS|dkrd}nJ|dvr d|d|odd}n;|dvrd|dȝ}n0| d|d|odd}n#|odkrd|od̛d͝}n|odkrd|oddϝ}nd|od̛d}jd|Ud<|VddŠY|rd tjd|~d tH}jd|d tjd|d t|U|Vkr&d|Vdםrd}Ud}*d }W {&d|Vdٝtjjd|Vd۝| || d |#d|Vd|d dݜSt|Udd߬}jd|d̛d|dd ttjId|Ud<|VddŠY|rd|~t?j|z}d}t?j|kr߉jar[jdd t| |d|d|Ud<|Vd| |#d d dSt?jd|dz }|dzdkrBmd|Ud<|Vdt|t?jz dt?j|kߐ Uj$dwkrpt |edd }t |edd }d }t|tr|Ed}nt |dd }|dkr|dvrd}dndm}dnj$d kr/}||ej}dnj$dkr1}||e}|j}dnj}||e}|j}d|}|d|| r!jdd td}d|ddkr؉jdd td }}j$d kr||ej}n||e}|}|rt |dCd nd }|rtt |d@d nd }t|o!tjd|tj}| o|o|d ur| p|d u}|rWd}jdd td}| | ||| |#d d |dSj$dvr*|}|%|s"|'dz }'||d}| ?||jr|)?|j|'d-krZjd|'dddd}| ?|| _| d }c*n5dY|)X}| | ||pd | |#d d ddSj$dvr|}||r|(dkr'|(dz }(jdd tjdd t| | |d | |#d d ddSt[| dkrhjd| }| | |d ||#d d ddSjdd t| |d | |#d d ddvStq|edr |ejrt|ejj2j$}|j}|j}|j}|||d}jM|t jMd d rjMjS}t jMd d rFtj1j|Ajd |d)d j1d jM_d jM_xj|z c_xj|z c_xj|z c_xjdz c_xj|jz c_xj|jz c_xj|jz c_xj|jz c_xj|jz c_d}|jr#|r!d |jd<|dd|jz|z dd}t^0djj1j2pd||||o| tj1|j2jt dd}|j#xjt|jz c_|j_|j_jCrjr jsjCj|j|j|j|j|j|jt|jnd |j|jj2j|jdkrdnd j1dn:#t $r-}t^Kdj||Yd }~nd }~wwxYwjr8tjKd|dd)d|dd)d|dd)|j}|j}|d}|s|rIj@sB|dkr ||z dznd}jd|d)d<|d)d|dd |d)d! d }aj2dnkr# dd"lm}|n#t $rYnwxYwmd#|#d$$n #t$rKrKdd Kjrdt?j|Tz }jd%d t| |d }%d&|d̛d'}$Y#not $#r[}KrKd(d Kjrdt|tr8t d)dd*kr t|}d+|vpd,|v}d-|vpd.|vo| }t!| }t|Athrt!|Ard }t|ftrt|frd }tt d/d thrt!jrd }|s|rYxjdz c_|r!jd0d tn jd1d tYd }~9|rd _t| }t|Athrt|At|ftrtU|fd }tt d/d thrtj}d }tt d2d thrtjQ}d }t|tr!t|}||kr |}|_Bd }tt d3d tr)tj}|jkr |_d }d }tt d4d trjEd5nd }t|trtU|}d }t dd pd}|rt|}||kr|_tt d4d tr |jd<t dd &tqjdr|j_d }jd6d txjdz c_|p |p|p|p|p|}|r!jd7d tn jd8d tYd }~*d} tt |d9d pt |dd pt|}n#t $rYnwxYwt |d:d }d;}|Ft Ffd<|D}|d upd=t|cxkod>knc}t d?d rn|rl|rjd _#t | }t|Athrt |Ajd@|rdAndqzd tYd }~it |d:d }‰|}t dBd }|rt |ĐdCdDndD}Őt|t ddpdt ddpd|P||Art[|AndE}t^KdF|Ɛj j |Ɛj |Ɛj |Ɛj |Ɛj|Ɛj||a|Ɛj |ÐG\}}a|rYd }~||Ɛj t"jkr[|^sYd }^|Ar&jdHd tYd }~t^0dI|Ɛj t"jkrj$d krjr|_sd }_t dJd spd _ jn#t $rYnwxYwjdKd tYd }~j$dwkrfj2dLvr\|dMkrU|YsSd }Yd tr:j2dNkrdOndP}ȉjdQ|țdRYd }~ j$dSkrj2dnkrx|dMkrp|[smd }[d trt7jdTYd }~ lddUlm}|ɦ}d} t |d9d pt |dVd }|́t|̦d dW}n#t $rYnwxYwt7jdX|rt7jdY|˛t7jdZt7jd[t7jd\t7jd]t7jd^|ʛd_t7jd`j2dakrD|dMkr=|\s;d }\r$jdbYd }~!j$d kr|dMkrtqdcr|Zsd }Zdddlm }!rt7jdeYd }~"Zj"}||Φrdfndg}ϐt7jdht7jdi|ϛt7|r+t[|Φdjkrjdk|d djdn jdlt7jd[ddUlm}|ɦ}ʐt7jdm|ʛdnt7jdo|ʛdpt7jdqt7jdrt7jdst7jdt|Ɛj t"j#kr|]sd }]| D].}1t|1tr|1dud /jdvd ttjIdwjt[| Yd }~$S|Ɛj t"j$kr|`sd }` ddxl%m&}|ЉjQ\}}n5#t $r(}tjIdyj|Ӧd}Yd }~nd }~wwxYw|rFjdz|қd{d ttjId|j|ҦYd }~% tjId}j|Udz }Ut?j|Tz }ԉmd~|Ud<|VdȝtO|jz}t|H(|}t^Id|U|V|Չ|֦t dd}t dd}Gt dd}|rd|›dnd}ىjd|Ud<|Vd|՛|ٛd tjd|כd|؛d tjd|Gd tjd|֛d t|rY|d>krRt |d9d }|rt|d dnd }|r"jd|ڛd tjd|ddt[|Ad|Pd)dl)rdHvrjd|؛dd tj*r@jdd tjdd tjd|؛d tjarjdd t| |d|՛dt|d| |#d d dcYd }~St |d:d }|Ɛj t"j+kr+dD}ۉjM}|jS}||kr|ܐ,j1|ۉjt ddj2tq|ܐd rd |_d |_jd|d)d|d)dld t|*dz }*|*|Xkrt[| }މU| ||P| .\} }d }t[| |ks||kr?&d|d)d|d)dt?jd*d }bYd }~n?|Ɛj t"j-t"j.hv}|rjt[jkrnt_j0j2t dd }|s>&d|Ɛj r d}Ud}*d }WYd }~*y|rj2dnkr|Ɛj t"j-kr|sd } ddlm1}m2}t |dVd }|rt |dd nd }||j3}|r|||Ðntj0dn#t $rYnwxYw|r|V}UYd }~++|Ɛj t"j4k}|dkrtjtrdjvrjdd tjdd tjdd tjdd tjdd t|r|*dz }*|*|Xkrjd|Xdd tjdd ttjjd|Xd| || d |#d|Xdd d d dcYd }~S&d|*d<|Xdt[| }މU| ||P| .\} }d }t[| |krJ&d|ޛdt[| dt?jd*d }bYd }~ njdd tjdd ttjjd| || d |#dd d d dcYd }~S|Ɛj t"j5k}|rƉjM}|jS}ݐtmH}|tod|dz }|_8jd|d)d|d)d|d)dȝd t|*dz }*|*|Xkrjd|Xdd tjdd ttjjd|Xd| || d |#d|Xdd d d dcYd }~Sd }bYd }~ ntsH}t ddpd}t ddpd:d<}|dvp|젲d}|o |d uodHv}|r2||kr,|}jd|d)d|d)dȝd tn:|r(|}jd|d)dd tntw|ݦ}|r||kr|ܐ,j1|jt ddj2tq|ܐd r!d |_t|o||k|_jd|d)d|d)dld tn jdÝd t|*dz }*|*|Xkrjd|Xdd tjdd ttjjd|Xd| || d |#d|Xdd d d dcYd }~S&d|Pd)d|*d<|Xdt[| }މU| ||P| .\} }d }t[| |ks|rc||kr]t[| |kr,&d|ޛdt[| dt?jd*d }bYd }~n݉jdƝd tjdǝd ttjjd|Pd)dɝ| || d |#d|Pd)d˝d d d dcYd }~St|ttfoAt|ttj<f ot|tzj> }|pv|Ɛj om|Ɛj od|Ɛj t"j-t"j.t"j?t"j5t"j4t"j+t"j#hvo| }|r?&d|›d͝r d}Ud}*d }WYd }~3|f|fd|Ϧ&d|›d҉(|jd|›dҝd tjd|כd|؛d tjd|Gd t|Ɛj@s|Ɛj t"j.kry|אdLvr|dMkr|אdkrjdԝd tjd՝d tjd֝d tjdםd tnjd؝d tjdٝd tnÉjdڝd tjd۝d tjd|؛d]d ttt|Gdݦr jdޝd tn jdߝd ttjjd||d=kr;|Pdkst[|Adkr!jdd tn| |d | |#d d t|dvcYd }~S|U|Vkr|Ws$B||U|Vr d }Wd}UYd }~7&d|Vdr d}Ud}*d }WYd }~7>(|}|r&d|Vd|n&d|Vd|jd|d tt |d:d  ot HfddD}|r@jdd tjdd ttjdj|V|||t[|A|Pd)|f|fd|Ϧ| |d|Vd|}|r|dz }|| |#d d |dvcYd }~Sd }|rt t |dVd dd }|r{tq|dri|Edp|Ed}|r; tt|d}n#ttf$rYnwxYw|r|nt|Udd}|r&&d|d̛d|Udzd<|Vdn!&d|d̛d|Ud<|Vdt^Id||U|V|t?j|z}d}t?j|krjar^jdd t| |d|Ud<|Vd| |#d d dcYd }~St?jd|dz }|dzdkrCmd|Ud<|Vdt|t?jz dt?j|kYd }~nd }~wwxYw|U|Vk;|%rd}+n|br(|#dz}#j+D|Udz }Ud }bE|cr3jrjnd}||'dzz}t|d_8F |e4d}+t7jd| |n }i}j$d kr j|d<|j|efi|}|}|j}d|jt|jtst|j}t|trH|EdIdp*|EdCdptj||_nt|thrg}|D]}t|tr|?|-t|trD|EddIkr*|?|EdIdt|tr,dI|vr(|?t|dIdY||_nt||_ dd!lGmH}t |d@d pg}|jpd}| did|| d}jpdd#j3pddj1dj2djdj$d|#d|odT|ddt[|Adt |edd dV|edE|ed|dt[|dt[|n#t $rYnwxYw|jrj@sxjr&jd |jnKjd |jd dt[|jdkrdnd|jrjFr|jX}tjGd d|X}|r%|Hddd dnd}|rAt d ddkr+ Fd |nJ#t $rYn>wxYw|r7 Fd d |d d>d n#t $rYnwxYwt|jpdrԉxjdz c_jdjd*kr)jdjdJjdd td_| }| | |d ||#d d ddSd_j$dwkr|ddkrxjdz c_||d}t|EdCpdX}t|EdStr5t|EdSdXnd }t|Ed}t|Ed}|s |s|s|r| r| dGnd }t|tr|Ednd } |Ed} t|tr|Ednd } |Ed} t|to|Ed>d?ko|EdTdkoq|EdCpd|EdCpdko@|EdSpd|EdSpdko| | ko| | k} | s+| ?|J|jd-krLj@s'jdjd| _| Nyd_| |d | |#d d ddStqdrd_|jK rj@s5jdt[|jKdjrL|jKD]CJtjKdJjLjMdJjLjNd dWdD|jKD]~JJjLjMj=vreOJjLjM}|r>t7jdJjLjMd|d|JjL_Mfd|jKD}|rxjdz c_dŠYtj=}|d}t[|dkr|d ddzn|}jd |d!jdjd-krKjd"d td_| |d | |#d d d#|dS||d}| ?||jKD]gJJjLjMj=vrd$JjLjMd%|}nd&}| ?dAJjLjMJjQ|d'hQ|d_gI|jKD]+JJjLjN}t|tthfr$tj|JjL_NU|Ct|ts-t|JjL_NJjLjN}|r|Xsd(JjL_N tj|#tj<$r=}I?JjLjMt|fYd }~%d }~wwxYwIrߐt Ifd)|jKD}|r`jd*|dd+d td_| | |d | |#d d ddSxjdz c_Id\}Hjd,|d-Hjd-kr(jdjdSjd.d_||d}| ?|d/ID}|jKD]tJJjLjM|vr+tJfd0ID}d1|d2}nd3}| ?dAJjLjMJjQ|d'uTd_S|jK|_KT|jK|_K||d}|jpd}|rى|rÐ|_thd4EtEfd5|jKD}|_|rrd _n[WrF|X}|rd6|d }| rt| dGtrj| dGEdUrO| d }| r6t| dGtr| dGEdUO|rd_d_d _| ?|J|jXr( Xd n#t $rYnwxYwY|| | |#j"fj"} d7}+Z| }$&d8| j[d| j\| ?d?|$d n^d}(d _]d9|jKD}!|!d:hkrj+DjM}|Đj^dkr |Đj^}"nt| jQpd ;}"jLrV|Đ |"r?Ad<U| |jMj^| .\} }d }| _| X^|jpd}$d _|$st d=dpd}#|#ryd>}+|#X}$t^0d?t[|$&d@|$}$d __ nt dAd }%|%rt dBd r{dC}+t^0dD&dEd _d _d_|%X}$d __nt dF| dGd D}&ttjdH|$pdtj}'|&rt dId s|'sd _d _d _t^0dJ&dK||d}(dL|(dC<d |(dM<| ?|(| ?ddNd dOZtt |dSd p&t |dPd pt |dud p|'})|)rjd*krxjdz c_t^0dQj&dRjdS|d}d |dU<| ?|| _| [͉|$X }*|)o jd*k}+|*rj|)r|+rdjd-krYxjdz c_t^IdTjj1&dUjd\s|*rjrt^IdVjj1j2&dWrXd_&dXj1dj2dȝt^0dYj1j2],dZ}+`|},a| ||d}dL|dC<d |d[<| ?||,r\t[|,d>kr|,d d>dzn|,}-t^Id\|-&d]nQt^Id^jj1j2&d_jrd`ndazdL}$n}d_d_j$dwkrj=r|&d*krb||$| br|&dz }&|d}| ?|J|ddcd}| ?|| _| _ d}&|)rdY|)|$z}$g})d}'|$X}$||d}.| rt| dGtr| dGEdUs8| dGEdMs| dGEd[r| | rnt| dGtrS| dGEdUL| dGEdMh| dGEd[| ?|.dd|ddȝ}+j@sAde|#dfn*#t $r}dg|#dt|H t7dhHn4#ttf$rt^HYnwxYwt^Kdi|#d jtt[| dz dGdGD]}B| |B}Ct|Ctsn|CEd>dAkr<|CEd>d?kr|CEd@rdk| |Bdzd D}/|Cd@D]}JJrtJtsJdl|/vrSdAtjdeJJdldmHd'}0| ?|0~|#j*dz kr4dnHd ddȝ}+doH}$| ?d?|$dYd }~n1Yd }~nd }~wwxYw|#j*krj+jhdkbjib|$D|#j*ksj+jhdkr(dp|#d<j*dȝ}+&dq|#d<j*drj@s"Ad;|#d<j*dsf| |#}$tjhEdt}1|1r tidu|1dv|#d<j*dwdx| yt^0dz|1|#j*n0#t $r#t^Id{|1d jYnwxYw|$d uo |#j*k}2j| tY||2| a| | || r| dGEd>nd }3d }4|3dAkrt| D]}1|1Ed>d?krp|1Ed@r[|1d@}5|5rMt|5dtr1|5dGEdXiEd\}4ntsd|| D}6|$rt[|$nd}7j+r j+jond}8j+r j+jpnd}9d}}:|+j1|#j*|8|9|6|3|7jpdf };|3dAkr"|%s t_jId~|:zdzg|;|4Rnt_j0|:g|;R|$r|%s t dd pi}<|t^Kd|>Yd }>~>n d }>~>wwxYw|$r|%s dd!lGmH}|d|$jpdj1t d#d pd}?|?D]!}@t|@tr|@r|@}$n"n3#t $r&}t^Id|Yd }~nd }~wwxYw|$ry|%sw dd!lGmH}|dj||$ti| j1t d#d pdn3#t $r&}t^Id|Yd }~nd }~wwxYwd }At| D]V}C|CEd>dkrn:|CEd>d?kr |CEdSr |CdS}AnWid|$d|Ady| d|#d|2d|+dd d|%dt dd dj1dj2djdjdjdjdjdjjjjt jMddpdjjjd}Bj"j"m|Bd<v}C|Cr|C|Bd<d __|%rjcr jc|Bd<d _d }Djtdkr#jujtkrdFj=vr d }Dd_un||$|%|$rA|%s?|s|Dr: oti| ||Dn#t $rYnwxYw dd!lGmH}|dj|2|%j1t d#d pdn3#t $r&}t^Id|Yd }~nd }~wwxYw|BS(a Run a complete conversation with tool calling until completion. Args: user_message (str): The user's message/question system_message (str): Custom system message (optional, overrides ephemeral_system_prompt if provided) conversation_history (List[Dict]): Previous conversation messages (optional) task_id (str): Unique identifier for this task to isolate VMs between concurrent tasks (optional, auto-generated if not provided) stream_callback: Optional callback invoked with each text delta during streaming. Used by the TTS pipeline to start audio generation before the full response. When None (default), API calls use the standard non-streaming path. persist_user_message: Optional clean user message to store in transcripts/history when user_message contains API-only synthetic prefixes. or queuing follow-up prefetch work. Returns: Dict: Complete conversation result with final response and message history rr providermodelr-r1_memory_write_originassistant_toolNFTanthropic_messagesu~🔌 Detected stale connections from a previous provider issue — cleaned up automatically. Proceeding with fresh connection.Pz...  zPconversation turn: session=%s model=%s provider=%s platform=%s history=%d msg=%rnoneunknownc3LK|]}|ddkdV dS)roleuserNget.0ms r8 z#run_conversation..s?  quuV}}/F/FA/F/F/F/F  r:rV_stream_context_scrubber_stream_think_scrubbermemoryrU)rTcontentu💬 Starting conversation: '<' system_prompt) invoke_hookon_session_startplatform) session_idrJrfz on_session_start hook failed: %sz*Session DB update_system_prompt failed: %s)rctoolszDPreflight compression: ~%s tokens >= %s threshold (model %s, ctx %s),u📦 Preflight compression: ~z tokens >= z# threshold. This may take a moment.) approx_tokensr@ pre_llm_call_user_id)rgr;r> is_first_turnrJrf sender_idcontextz zpre_llm_call hook failed: %scodex_app_server)r;original_user_messagemessageseffective_task_idshould_review_memoryinterrupted_by_useru2 ⚡ Breaking out of tool loop due to interrupt...zstarting API call #budget_exhaustedu% ⚠️ Iteration budget exhausted (/z iterations used)rT assistant tool_callstool tool_call_idr`cg|]h}t|t|dd|d|dddiS)functionnameid arguments)rresultr isinstancedictrX)rZtc_results_by_ids r8 z$run_conversation..=s~&&& !#)"d33&(*:v(>*8*<*.2s.@@C#c#hh--@@@@@@r:u🔄 Making API call #u 📊 Request size: z messages, ~z tokens (~z chars)u 🔧 Available tools: )brainsparklepulsemoonstar) spinner_typeprint_fnzAPI Request - Model: z , Messages: z , Tools: zLast message role: zTotal message size: ~z tokensstopnous)r#format_remainingu,Nous Portal rate limit active — resets in .u⏳ z Trying fallback...)forcezg No fallback provider available. Try again after the reset, or add a fallback provider in config.yaml.)final_responsers api_calls completedfailederrorcodex_responses) allow_streamrsinputpre_api_requestr@rgr;r>base_urlapi_modeapi_call_countrequest_messages message_count tool_countapprox_input_tokensrequest_char_count max_tokensHERMES_DUMP_REQUESTS preflight)reasoncvrddjrddSdS)NrI)rthinking_callback)agentthinking_spinnersr8 _stop_spinnerz'run_conversation.._stop_spinnersT'0(--b111+/(.4//3333344r:_disable_streamingz copilot-acpz acp://copilotz acp+tcp://)Mockclient)on_first_deltau⏱️ API call completed in z.2fszN/AzAPI Response received - Model: z , Usage: usagezresponse is Nonestatus>r cancelledrmessagezResponses API returned status 'z>Codex response status='%s' (error=%s). Routing to fallback. %szresponse.status=z: output_textzaCodex response.output is empty but output_text is present (%d chars); deferring to normalization.incomplete_detailszeCodex response.output is empty after stream backfill (status=%s, incomplete_details=%s, model=%s). %sz api_mode=z provider=zresponse.output is emptyz/response.content invalid (not a non-empty list)bedrock_conversez/Bedrock response invalid (no output or choices)choicesz#response has no 'choices' attributezresponse.choices is Nonezresponse.choices is emptyu(´;ω;`) oops, retrying...u<⚠️ Empty/malformed response — switching to fallback...Unknownmetadata provider_namezmodel=cni|]2\}}|d|t|dd3S)_Nd) startswithr<)rZkvs r8 z$run_conversation..sA%r%r%r$!Q`a`l`lmp`q`q%raQ%r%r%rr:z*Response attributes for invalid response: codei z-upstream provider timed out (Cloudflare 524, z.0fzs)izupstream gateway timeout (504, iz'rate limited by upstream provider (429)>zupstream server error (z, >zupstream provider overloaded ()zupstream error (code zfast response (z.1fus) — likely rate limitedzslow response (us) — likely upstream timeoutzresponse time u&⚠️ Invalid API response (attempt z): u 🏢 Provider: u 📝 Provider message: u ⏱️ u⚠️ Max retries (u.) for invalid responses — trying fallback...u❌ Max retries (z,) exceeded for invalid responses. Giving up.zInvalid API response after z retries.z retries: )rsrrrrg@g^@) base_delay max_delayu⏳ Retrying in zs (z)...zInvalid API response (retry z | Provider: u3⚡ Interrupt detected during retry wait, aborting.z$Operation interrupted during retry (z , attempt z).)rrsrr interruptedg?zretry backoff (z), z s remainingr incomplete>lengthmax_output_tokensruA⚠️ Treating suspicious Ollama/GLM stop response as truncateduQ⚠️ Response truncated (finish_reason='length') - model hit max output tokens)strip_tool_prefixz8<(?:think|thinking|reasoning|REASONING_SCRATCHPAD)[^>]*>zModel used all output tokens on reasoning with none left for the response. Try lowering reasoning effort or increasing max_tokens.uV💭 Reasoning exhausted the output token budget — no visible response was produced.u ⚠️ **Thinking Budget Exhausted** The model used all its output tokens on reasoning and had none left for the actual response. To fix this: → Lower reasoning effort: `/thinkon low` or `/thinkon minimal` → Or switch to a larger/non-reasoning model with `/model`)rrsrrpartialr>rchat_completionsrMu↻ Requesting continuation (z/3)...z[System: Your previous response was truncated by the output length limit. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z9Response remained truncated after 3 continuation attemptsu=⚠️ Truncated tool call detected — retrying API call...uf⚠️ Truncated tool call response detected again — refusing to execute incomplete tool arguments.z-Response truncated due to output length limitu3 ⏪ Rolling back to last complete assistant turnu-❌ First response truncated - cannot recoverz3First response truncated due to output length limit)rHr) prompt_tokenscompletion_tokens total_tokens_context_probed_context_probe_persistableu💾 Cached context length: z tokens for z cache=z (rz%)zHAPI call #%d: model=%s provider=%s in=%d out=%d total=%d latency=%.1fs%sapi_key)rHrrincludedsubscription_included) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokensestimated_cost_usd cost_status cost_sourcebilling_providerbilling_base_url billing_moderJrz4Token persistence failed (session=%s, tokens=%d): %szToken usage: prompt=rz , completion=rz, total=ru 💾 Cache: z tokens (z% hit, z written))r!z API call #z completedu ⚡ Interrupted during API call.z3Operation interrupted: waiting for model response (z s elapsed).u(╥_╥) error, retrying..._unicode_sanitization_passesz'ascii'ascii surrogatez'utf-8'prefill_messagesuH⚠️ Stripped invalid surrogate characters from messages. Retrying...uP⚠️ Surrogate encoding error — retrying after full-payload sanitization...rhephemeral_system_prompt_client_kwargsdefault_headersu⚠️ API key contained non-ASCII characters (bad copy-paste?) — stripped them. If auth fails, re-copy the key from your provider's dashboard.ud⚠️ System encoding is ASCII — stripped non-ASCII characters from request payload. Retrying...uT⚠️ System encoding is ASCII — enabling full-payload sanitization for retry...body status_code)z%only 'text' content type is supportedz#only text content type is supportedzimage_url is not supportedzimage content is not supportedzmultimodal is not supportedz#multimodal content is not supportedz!multimodal input is not supportedzvision is not supportedzvision input is not supportedzdoes not support imageszdoes not support image inputzdoes not support multimodalzdoes not support visionzmodel does not support imagezimage_url'. expectedz,unknown variant `image_url`, expected `text`z(unknown variant image_url, expected textc3 K|]}|vV dSr)rZp _err_lowers r8r\z#run_conversation..:s822()AO222222r:ir_vision_supporteduV⚠️ Server rejected image content — switching to text-only mode for this sessionz,. Stripped images from history and retrying.context_compressorcontext_lengthi@ )rHrJrkr num_messageszTError classified: reason=%s status=%s retryable=%s compress=%s rotate=%s fallback=%s)r has_retried_429classified_reason error_contextuE📐 Image(s) exceeded provider size limit — shrank and retrying...zlimage-shrink recovery: no data-URL image parts found or shrink didn't reduce size; surfacing original error._oauth_1m_beta_disabledui🔕 OAuth subscription doesn't support the 1M-context beta — disabled for this session and retrying...> xai-oauth openai-codexirz xAI OAuthCodexu🔐 z. auth refreshed after 401. Retrying request...ru<🔐 Nous agent key refreshed after 401. Retrying request...r+responseu/🔐 Nous 401 — Portal authentication failed.z Response: zS Most likely: Portal OAuth expired, account out of credits, or agent key revoked.z Troubleshooting:u6 • Re-authenticate: hermes login --provider nousuA • Check credits / billing: https://portal.nousresearch.comu$ • Verify stored credentials: z /auth.jsonuK • Switch providers temporarily: /model --provider openroutercopilotuA🔐 Copilot credentials refreshed after 401. Retrying request..._anthropic_api_keyruC🔐 Anthropic credentials refreshed after 401. Retrying request...zBearer (OAuth/setup-token)zx-api-key (API key)u-🔐 Anthropic 401 — authentication failed.z Auth method: z Token prefix: z Token: (empty or short)u" • Check ANTHROPIC_TOKEN in z+/.env for Hermes-managed OAuth/setup tokensu$ • Check ANTHROPIC_API_KEY in z)/.env for API keys or legacy token valuesuJ • For API keys: verify at https://platform.claude.com/settings/keysuD • For Claude Code: run 'claude /login' to refresh, then retryu= • Legacy cleanup: hermes config set ANTHROPIC_TOKEN ""uA • Clear stale keys: hermes config set ANTHROPIC_API_KEY ""reasoning_detailsuV⚠️ Thinking block signature invalid — stripped all thinking blocks, retrying...zP%sThinking block signature recovery: stripped reasoning_details from %d messagesr/z5%sllama.cpp grammar recovery: strip helper failed: %su<⚠️ llama.cpp rejected tool schema grammar — stripped z' pattern/format keyword(s), retrying...zU%sllama.cpp grammar recovery: stripped %d pattern/format keyword(s) from tool schemasue%sllama.cpp grammar error but no pattern/format keywords to strip — falling through to normal retryzAPI error recovery (attempt z;API call failed (attempt %s/%s) error_type=%s %s summary=%sz [HTTP ]u!⚠️ API call failed (attempt u 🔌 Provider: z Model: u 🌐 Endpoint: u 📝 Error: i,u 📋 Details: u ⏱️ Elapsed: z s Context: z msgs, ~zsupport tool useu$ 💡 No OpenRouter providers for z1 support tool calling with your current settings.zU Your provider_routing.only restriction is filtering out tool-capable providers.zY Try removing the restriction or adding providers that support tools for this model.zH Check which providers support tools: https://openrouter.ai/models/u?⚡ Interrupt detected during error handling, aborting retries.z+Operation interrupted: handling API error ()rJrrrrHuO⚠️ Anthropic long-context tier requires extra usage — reducing context: u → u🗜️ Context reduced to z tokens (was z), retrying...)rHru9⚠️ Rate limited — switching to fallback provider...)r"r$headers)r last_known_state)r rzNous 429 looks like upstream capacity (no exhausted bucket in headers or last-known state) -- not tripping cross-session breaker.izmodels.inference.ai.azure.comuJ 💡 GitHub Models free tier (models.inference.ai.azure.com) caps everyzJ request at ~8K tokens. Hermes' system prompt + tool schemas baselinezF exceeds that floor, so this endpoint cannot run an agentic loop.zK Use the `copilot` provider with a Copilot subscription token (`hermesu= setup` → GitHub Copilot), or pick any other provider.u❌ Max compression attempts (z&) reached for payload-too-large error.uR 💡 Try /new to start a fresh conversation, or /compress to retry compression.z413 compression failed after z attempts.z5Request payload too large: max compression attempts (z ) reached.)rsrrrrrcompression_exhaustedu@⚠️ Request payload too large (413) — compression attempt u🗜️ Compressed z messages, retrying...u2❌ Payload too large and cannot compress further.z/413 payload too large. Cannot compress further.z9Request payload too large (413). Cannot compress further.@uM⚠️ Output cap too large for current prompt — retrying with max_tokens=z (available_tokens=z; context_length unchanged at z!Context compression failed after z3Context length exceeded: max compression attempts (> minimax-cnminimax)z https://api.minimax.io/anthropicz"https://api.minimaxi.com/anthropiczcontext window exceeds limit (z!Context limit detected from API: zBProvider reported overflow amount only; keeping context_length at z tokens and compressing.u3⚠️ Context length exceeded — stepping down: uM⚠️ Context length exceeded at minimum tier — attempting compression...u🗜️ Context too large (~u tokens) — compressing (u8❌ Context length exceeded and cannot compress further.u 💡 The conversation has accumulated too much content. Try /new to start fresh, or /compress to manually trigger compression.zContext length exceeded: z! tokens. Cannot compress further.zContext length exceeded (z" tokens). Cannot compress further.u!⚠️ Non-retryable error (HTTP u) — trying fallback...non_retryable_client_error)rru❌ Non-retryable error (HTTP u%❌ Non-retryable client error (HTTP z ). Aborting.ruK 💡 Codex OAuth token was rejected (HTTP 401). Your token may have beenz? refreshed by another client (Codex CLI, VS Code). To fix:z? 1. Run `codex` in your terminal to generate fresh tokens.z3 2. Then run `hermes auth` to re-authenticate.u8 💡 xAI OAuth token was rejected (HTTP 401). To fix:zW re-authenticate with xAI Grok OAuth (SuperGrok Subscription) from `hermes model`.u9 💡 Your API key was rejected by the provider. Check:u- • Is the key valid? Run: hermes setupu+ • Does your account have access to z openrouter.aiu? • Check credits: https://openrouter.ai/settings/creditsu6 💡 This type of error won't be fixed by retrying.zNon-retryable client error: iPuU⚠️ Skipping session persistence for large failed session to prevent growth loop.) retry_count max_retriesu") exhausted — trying fallback...u❌ Rate limited after u retries — u❌ API failed after u 💀 Final error: c3 K|]}|vV dSrr )rZr  error_msgs r8r\z#run_conversation.. s7  1Y      r:)zconnection lostzconnection resetzconnection closedznetwork connectionz network error terminatedu 💡 The provider's stream connection keeps dropping. This often happens when the model tries to write a very large file in a single tool call.z~ Try asking the model to use execute_code with Python's open() for large files, or to write the file in smaller sections.zP%sAPI call failed after %s retries. %s | provider=%s model=%s msgs=%s tokens=~%smax_retries_exhaustedzAPI call failed after u The provider's stream connection keeps dropping — this often happens when generating very large tool call responses (e.g. write_file with long content). Try asking me to use execute_code with Python's open() for large files, or to write in smaller sections.rXz retry-afterz Retry-Afterxg@gN@u⏱️ Rate limited. Waiting z s (attempt z4Retrying API call in %ss (attempt %s/%s) %s error=%sz_delegate_depth _thinkingzreasoning.availableuL⚠️ Incomplete detected (opened but never closed)u🔄 Retrying API call (z/2)...uA❌ Max retries (2) for incomplete scratchpad. Saving as partial.z/Incomplete REASONING_SCRATCHPAD after 2 retriescodex_reasoning_itemscodex_message_itemsu0↻ Codex response incomplete; continuing turn (z/3)z@Codex response remained incomplete after 3 continuation attempts_codex_incomplete_retriesu🔧 Processing z tool call(s)...z Tool call: z with args: u🔧 Auto-repaired tool name: 'z' -> 'cNg|]!}|jjjv|jj"Sr )r~rvalid_tool_names)rZrrs r8rz$run_conversation.. s;&&&)+{'u/EEEK$EEEr:u⚠️ Unknown tool 'u3' — sending error to model for agent-correction (uI❌ Max retries (3) for invalid tool calls exceeded. Stopping as partial.z#Model generated invalid tool call: zTool 'z#' does not exist. Available tools: zZSkipped: another tool call in this turn used an invalid name. Please retry this tool call.)rTrr|r`z{}c3K|]P}|jjdDv|jjpdd VQdS)ch|]\}}|Sr r )rZnrs r8 z-run_conversation...+ s/P/P/Pda/P/P/Pr:rI)}rN)r~rrrstripendswith)rZrinvalid_json_argss r8r\z#run_conversation..( sv%%;+/P/P>O/P/P/PPP [28b@@BBKKJWWWPPPP%%r:u>⚠️ Truncated tool call arguments detected (finish_reason=u) — refusing to execute.u1⚠️ Invalid JSON in tool call arguments for 'z': u;⚠️ Injecting recovery tool results for invalid JSON...ch|]\}}|Sr r )rZrrs r8r@z#run_conversation..T s(O(O(O'$(O(O(Or:c3BK|]\}}|jjk|VdSrr~r)rZr?ers r8r\z#run_conversation..W s8*d*dAaSUS^ScNcNc1NcNcNcNc*d*dr:zError: Invalid JSON arguments. z_. For tools with no required parameters, use an empty object: {}. Please retry with valid JSON.z;Skipped: other tool call in this response had invalid JSON.>todor_rsession_searchc34K|]}|jjvVdSrrG)rZr_HOUSEKEEPING_TOOLSs r8r\z#run_conversation.. sB,, (,??,,,,,,r:u ┊ 💬 guardrail_haltu⚠️ Tool guardrail halted c&h|]}|jjSr rG)rZrs r8r@z#run_conversation.. sUUU"R[-UUUr: execute_code)rhu ⟳ compacting context… _current_streamed_assistant_textpartial_stream_recoveryuGPartial stream content delivered (%d chars) — using as final responseuD↻ Stream interrupted — using delivered content as final response_last_content_with_tools$_last_content_tools_all_housekeepingfallback_prior_turn_contentuOEmpty follow-up after tool calls — using prior turn content as final responseuM↻ Empty response after tool calls — using earlier content as final answerc3HK|]}|ddkVdS)rTr{NrWrYs r8r\z#run_conversation..V sE**f /******r:z||_post_tool_empty_retrieduHEmpty response after tool calls — nudging model to continue processinguD⚠️ Model returned empty after tool calls — nudging to continuez(empty)_empty_recovery_syntheticz~You just executed tool calls but returned an empty response. Please process the tool results above and continue with the task.)rTr`rXreasoning_contentuMThinking-only response (no visible content) — prefilling to continue (%d/2)u7↻ Thinking-only response — prefilling to continue (z/2)uBEmpty response (no content or reasoning) — retry %d/3 (model=%s)u/⚠️ Empty response from model — retrying (uOEmpty response after %d retries — attempting fallback (model=%s, provider=%s)uL⚠️ Model returning empty responses — switching to fallback provider...u↻ Switched to fallback: z.isP$$$%a..$4555==F3J3J.)3J3J3Jr:rzError executing tool: zerror_near_max_iterations(z0I apologize, but I encountered repeated errors: zmax_iterations_reached(u#⚠️ Iteration budget exhausted (u) — asking model to summariseu) — requesting summary...HERMES_KANBAN_TASK kanban_blockzIteration budget exhausted (u;) — task could not complete within the allowed iterations)r@r)r@zBkanban_block called for task %s after iteration exhaustion (%d/%d)zBFailed to call kanban_block after iteration exhaustion for task %sc3K|]I}t|tr2|ddk0|dEdVJdS)rTryrzrVNrrYs r8r\z#run_conversation..sf a  #$55==K#?#?AEE,DWDW#? #?#?#?#?r:zuTurn ended: reason=%s model=%s api_calls=%d/%d budget=%d/%d tool_turns=%d last_msg_role=%s response_len=%d session=%sz>Turn ended with pending tool result (agent may appear stuck). z last_tool=%s_turn_failed_file_mutationsz(file-mutation verifier footer failed: %stransform_llm_output) response_textrgrJrfz$transform_llm_output hook failed: %s post_llm_call)rgr;assistant_responser>rJrfzpost_llm_call hook failed: %srlast_reasoningrrturn_exit_reasonrrresponse_previewed_response_was_previewedrrrrrlast_prompt_tokens)rrrrkrrr guardrail pending_steerinterrupt_message)rrrr)messages_snapshot review_memory review_skillson_session_end)rgrrrJrfzon_session_end hook failed: %s)r)r0(pr%_ensure_db_sessionagent.auxiliary_clientr getattr Exceptionhermes_loggingr.rgtools.skill_provenancer2_restore_primary_runtimerr<r_stream_callback_persist_user_message_idx_persist_user_message_overrideuuiduuid4_current_task_id_invalid_tool_retries_invalid_json_retries_empty_content_retries_incomplete_scratchpad_retriesr:_thinking_prefill_retriesrWrRrS_mute_post_responser_tool_guardrailsreset_for_turn_tool_guardrail_halt_decisionrr_cleanup_dead_connections _emit_status_compression_warning_replay_compression_warningrmax_iterationsiteration_budgetr rreplacerinforJrHrflist _todo_store has_items_hydrate_todo_store_user_turn_countsum_memory_nudge_interval_turns_since_memoryresetr< _memory_storeappend quiet_mode _safe_print_cached_system_prompt _session_db get_sessionrX_build_system_prompthermes_cli.pluginsrdwarningupdate_system_promptdebugcompression_enabledrprotect_first_nprotect_last_nrrhthreshold_tokensrrange_compress_contextboolrstripjoinrb threadingcurrent_threadident_execution_thread_idr9_set_interrupt_interrupt_requested _interrupt_thread_signal_pending_interrupt_message_memory_manager on_turn_start prefetch_all_run_codex_app_server_turn remaining_budget_grace_call_checkpoint_mgrnew_turn_api_call_count_touch_activityconsumeused max_total step_callback enumeratereversed_skill_nudge_interval_iters_since_skill_drain_pending_steerrlogging getLogger__name___sanitize_tool_call_arguments_repair_message_sequencecopyr_copy_reasoning_content_for_apipop_should_sanitize_tool_calls#_sanitize_tool_calls_for_strict_apirrinsert_use_prompt_cachingr& _cache_ttl_use_native_cache_layout_sanitize_api_messages#_drop_thinking_only_and_merge_usersjsonloadsdumpsrrr_vprint log_prefixrandomchoicer get_thinking_facesget_thinking_verbsr_has_stream_consumers_should_start_quiet_spinner _print_fnstartverbose_loggingtime_api_max_retriesagent.nous_rate_guardr#r_try_activate_fallback_persist_session ImportError_reset_stream_delivery_tracking_build_api_kwargs_force_ascii_payloadr_get_transportpreflight_kwargsrrr4_dump_api_request_debuglowerr unittest.mockr!_interruptible_streaming_api_call_interruptible_api_callrhasattrrvalidate_response_client_log_contextr_fallback_index_fallback_chainrrrvarsitemsint TypeError ValueError_clean_error_messager'clear_interruptsleepmap_finish_reason stop_reasonnormalize_responser_should_treat_stop_as_truncated_is_anthropic_oauthresearch IGNORECASE_has_content_after_think_block_cleanup_task_resources_build_assistant_messager`_session_messages_save_session_log_strip_think_blocks"_get_messages_up_to_last_assistantr*rrrupdate_from_responser rrsession_prompt_tokenssession_completion_tokenssession_total_tokenssession_api_callssession_input_tokensrsession_output_tokenssession_cache_read_tokensrsession_cache_write_tokensrsession_reasoning_tokensrr) amount_usdsession_estimated_cost_usdfloatrsession_cost_statussourcesession_cost_source_session_db_createdupdate_token_countsr!InterruptedErrorUnicodeEncodeErrorrrrrrrranyr_extract_api_error_contextrrvaluer  retryableshould_compressshould_rotate_credentialshould_fallback_recover_with_credential_poolrimage_too_large#_try_shrink_image_parts_in_messages!oauth_long_context_beta_forbiddenr_anthropic_clientclose_rebuild_anthropic_client%_try_refresh_codex_client_credentials$_try_refresh_nous_client_credentialsprinthermes_constantsr,'_try_refresh_copilot_client_credentialsagent.anthropic_adapterr )_try_refresh_anthropic_client_credentialsrthinking_signaturellama_cpp_grammar_patterntools.schema_sanitizerr0r_summarize_api_error_is_openrouter_urlproviders_allowedlong_context_tier update_model rate_limitbilling!_pool_may_recover_from_rate_limit_credential_poolr"r$_rate_limit_statepayload_too_largecontext_overflowrmax_ephemeral_max_output_tokensrrBrJSONDecodeErrorsslSSLError overloadedis_authr3_try_recover_primary_transportminrefund#_usage_summary_for_api_request_hooktool_progress_callbacksubsplitr(_emit_interim_assistant_messagerzr~rr_repair_tool_callsortedrnext_cap_delegate_task_calls_deduplicate_tool_calls frozensetall _should_emit_quiet_tool_messagesstream_delta_callback_execute_tool_calls#_toolguard_controlled_halt_response tool_namer_stream_needs_breakrkrj_extract_reasoning)_drop_trailing_empty_response_scaffolding"_looks_like_codex_intermediate_ackOSErrorAIAgent_get_tool_call_name_static_handle_max_iterationsosenvironhandle_function_call_save_trajectory_file_mutation_verifier_enabled$_format_file_mutation_failure_footer to_metadata_sync_external_memory_for_turn_spawn_background_review(Lrr;r=r>r@rArCr r.r2rt _preview_text _msg_previewrsprior_user_turnsscrubberthink_scrubberrr_should_review_memoryuser_msgcurrent_turn_user_idx_print_preview stored_prompt session_row _invoke_hookexcrHactive_system_prompt_preflight_tokens_pass _orig_len_plugin_user_context _pre_results _ctx_partsrrrrcodex_ack_continuationslength_continue_retriestruncated_tool_call_retriestruncated_response_partscompression_attempts_turn_exit_reason _turn_msg_ext_prefetch_cache_query prev_tools_idx_m _fwd_start_tm_tcid _step_err_pre_api_steer _injected_si_smmarkerexistingblocks_lockrequest_loggerrepaired_tool_calls repaired_seq api_messagesidxrapi_msg _injections_fenced_baseeffective_system sys_offsetpfmamtcsnew_tcsargs_obj total_charsrkfaceverbrapi_start_timer'r(primary_recovery_attemptedmax_compression_attemptscodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attemptedcopilot_auth_retry_attemptedthinking_sig_retry_attemptedimage_shrink_retry_attemptedoauth_1m_beta_retry_attempted!llama_cpp_grammar_retry_attemptedr restart_with_compressed_messages restart_with_length_continuationrr api_kwargsr#_fmt_nous_remaining_nous_remaining _nous_msgrr_use_streamingrr1 resp_modelresponse_invalid error_details_ct_v_codex_resp_status_codex_error_obj_codex_error_msg _out_text_out_text_stripped _resp_status_resp_incomplete_tv_btv_ctvr resp_attrs_resp_error_code _code_raw _failure_hintcleaned_provider_error wait_time sleep_end_backoff_touch_counterrrincomplete_reason_tfr_bt_fr_bedrock_result_cc_fr_finish_resultr3 _trunc_msg_trunc_transport _trunc_result_trunc_content_trunc_has_tool_calls_has_think_tags_thinking_exhausted_exhaust_error_exhaust_response interim_msg continue_msgpartial_responserolled_back_messagescanonical_usagerrr usage_dictctx _cache_pct cost_resultcachedwrittenprompthit_pctr! api_elapsed api_error_err_str_is_ascii_codec_is_surrogate_error_surrogates_found_messages_sanitized_prefill_sanitized_tools_sanitized_system_sanitized_sanitized_system_sanitized_ephemeral_headers_sanitized_default_headers_credential_sanitized_raw_key _clean_key_any_sanitized _err_body _err_status_IMAGE_REJECTION_PHRASES_looks_like_image_rejection _status_ok _imgs_removedr r _compressor_ctx_len classifiedrecovered_with_pool_label_dhh_fn_dhh _body_text_bodyr key auth_methodr0r _stripped _strip_exc elapsed_time error_type_error_summary _provider_model_status_code_str _err_body_str _reduced_ctx compressorold_ctx original_lenis_rate_limitedpool_may_recover_genuine_nous_rate_limitr"r$ _err_resp _err_hdrsis_payload_too_largeis_context_length_error available_outsafe_out parsed_limit_provider_lower _base_loweris_minimax_providerminimax_delta_only_overflownew_ctxis_local_validation_erroris_client_error_final_summary_is_stream_drop_final_response _retry_after _resp_headers_ra_raw _boost_base_boost _transport_normalize_kwargs normalizedrawpartspart_assistant_tool_calls_assistant_text _think_text first_lineinterim_has_contentinterim_has_reasoninginterim_has_codex_reasoninginterim_has_codex_message_itemslast_msglast_codex_itemsinterim_codex_itemslast_codex_message_itemsinterim_codex_message_itemsduplicate_interimrepairedinvalid_tool_calls available invalid_nameinvalid_preview assistant_msgr`args _truncatedrfrecovery_assistant invalid_nameserr tool_result turn_content_all_housekeepingclean _had_prefilldecision _tc_names _real_tokens_partial_streamed _recoveredfallback_prior_was_tool_has_inline_thinking _nudge_msg_has_structured _truly_empty_prefill_exhaustedreasoning_textreasoning_preview final_msg answered_idserr_msg _kanban_taskr_last_msg_role_last_tool_name_tcs_turn_tool_count _resp_len _budget_used _budget_max _diag_msg _diag_args_failedfooter_ver_err_transform_results _hook_resultrgr_leftover_steer_should_review_skillsrLr rr*rDrrsL` @@@@@@@r8run_conversationrUs/<  ;;;;;; E:r * * 0b E7B ' ' -2          322222()))@?????WU,BDTUUVVV  ""$$$ ,$$:+L99 &,,J34HII-E&*E#+?E(43tz||#4#4 /E#$E"#E#$E +,E(&'E#&'E#%*E"%)E"16E. %E)*E& ))+++*.E' #E  ~--- ..00 """     D  !* ))+++%)" -U-ABBE4LAAM36}3E3E3J3JM#2#&..P]L''c22L KKZ "FEK1L9 #)S)=)C%D%D .BIt()))rH 8E$5$?$?$A$A8 !!"6777 \ 6! ; ;  +      a  %5E "+a//E4MQR4R4R-=u?[,[) a u8$??HU$>       *0AM**.?O***   q  MM 161H1Hn>>16..#' 16.   1;CCF"wwy"55H!(C00 !)1F):I!7?%GT(^^^RF"MM66*J*JKKK-3C NN(!!! D! $ILLVE n 'EEHQY+mHtOn,L,L_mE(!$77V7;LX;V;V#AA !'B    " "   X# 'C   55h?? !     X 'C     !(++* )* )HChhjjG+++60I0I &489LMMG4#**7333'=&&';<<<W#KK 266E!%--W-2V^fkk+>V>V-V *  1 1#w ? ? ?g%% K(((')) O,,, KK+T 2 2 2 0022 C99'BBB    ( ( ( ("052  ( c 06 9E>> 7799%*+K3409>6$..x9MNNN!Dy!D!D!D )1)7).&*%.   #D De 55777"44\BB ->1*===>%666!&!5!5!7!7!H!Hbg!H!h!hJ!NNNNNN'1~~j'A'A$%&6==C+5>>'+B+B(%&6==8+7(!L) 1 1$)#3#9r&;%:  .2(^^^  "'!52 $kk"'"'"'(6~DNN^`dCeCe)m.>)?)?)?km'*,&7&7&7$'u{'8b#9#9#9-:M ,7;!"$)#3#3#&!D##9::R11*[1QQQ444444"&5"6>>/%*NN Nm335>/R006688CCOTT45>/R006688CCLQQ4&+NN4466/322222!'%4"@"@$GG/).!I$FF"= G  HH %<%666!0022E 228<<-U#+/3,)001CDDDD 25WXxQS5T5T5ZXZ1[1[1a1a1c1c1i1i1k1k.15LLL3:8Wd3S3S 0GQRbdhGiGi%a$4$8$8$C$C$CBR*a-=)>)>)>)`K])`)`)`!1 !($d$68H$)$=$=$?$?!"!"!" 48 0 - 4 45pHZ5p5p^n5p5p q q q q-4HmT,R,R JTU^`cJdJd5lY__5F5F5Fjl 2#5!U$*LL)R(+,>(?(?%&%&%&%& 4;8Xt3T3TL7>xI]_c7d7d$4$*NN)[(46F(/'4(H(H(^EN(^(^en(^(^ %&%&%&8<$4$1$8$89S$T$T$T^';;;..00C00::d+/(#+)001CDDDD)001bccc^'999 //11D11(;;d+/(#+)001CDDDD)001bccc //11D11(;; N+/(#+)001CDDDD!(9!=!=N)001VWWWW%-5)001KLLLL)001LMMM#D'0(--.KLLL+/(.4//333 1$K ,s53H/I/III**+ijjj3355!&' /0,5:2 !*I$-M:GHg$>$>:8>:$'$7$7 "8>:>>d8>CZd,4N,C,G,GYb,c,cM!:gh &B&B:xGW:$'(8$9$9 % 11h178U\C]C]1bjbp1(A(A(A % 11h1%r%r$x..BVBVBXBX%r%r%r  0e#M*cWa*c*cddd(,$%GHg$>$>%8>%$+HNFD$I$I $,HND1Q1Q,(0(:(:6(B(BI$0%36y>> 0 0$-z#:%%% $% (3..(lXd(l(l(l(l )S00(^,(^(^(^(^ )S00(R )Z77(jBR(j(jVb(j(j(j(j )Z77(\IY(\(\(\ )5(h@P(h(hT`(h(h(h(h %**(f,(f(f(f(f %**(j,(j(j(j(j (L(L(L(L(L MMU%5#V#V]h#V#Vkv#V#V{|E|EFS|T|T#V#V^bMcccMMU%5"X"X"X"X`dMeee-2-G-G -R-R*MMU%5"i"iQg"i"iquMvvvMMU%5"Q"Q-"Q"QY]M^^^"k11**+}++}+}+}~~~ 7799%*+K3409>6$**+x{+x+x+xyyy )9&l&lVa&l&l&lmmm..x9MNNN(0).)7%i;%i%iZg%i%i&*   !1X] ^ ^ ^IMMU%5"l"ly"l"l"lYf"l"l"ltxMyyyO%X;%X%XQ\%X%Xaeajajkxayay%X%XIV%X%XYYY!% i 7I-.*)++ 11 5 !MMU-=*r*r*rz~M!228=QRRR!113333PYf3P3Pr}3P3PAL3P3P3P,4-;-2/3 $$ 3/!3.1C71<<!11!M+!M!M !M!M#&y49;;'>#?#?!M!M!M#)++ 11*>%666$Xx>>F)0;OQU)V)V&(,%!"4d;;X,>,B,B8,L,L)),34FRV,W,W)--2CGf2f2f(0 (. ^';;; //11D$($:$:8;O$P$PMM^'999"1133F&,&?&?&I&IO$3$AMM"1133F%+%>%>x%H%HN$2$@M(6%<<%)  1  $/rrr"&&)1  H,,MMU%5#I#I#IQUMVVV"&J',';';'='=$~)===(8(K(K$8Q)L)) )9(K(KH(U(U !.JMW%aWZD%I%I%I]aN]g,rD\SW1X1X,Y,Y,Ymr)'+&29W*M,,''O21+,47t@d@des@t@t> ;q @ ; % ','7$v$v$v*.!.!"!"!"!)!MM#(#3!\!\!\&**"99:KLLL!228=QRRR26,4-;-2+/)X $$8}}q(( )9&n&n&nooo/4/W/WX`/a/a,556GHHH..x9MNNN/3(<)7).'+%T    )9&h&h&hpt uuu..x9MNNN.2(0)7).&*%Z   8W--(.&5 !&!&'''O %4$AM(7(E%#2#?L)6->(4""J ,AA*MMM u79JERRT#6E"5#;=Y[`aaA/ U^SQQQ!--1A.._b...rwr}..AAACH0@NS0K//=@//337HH33..,>..++q0++../2NN..//?3PP//337XX33448ZZ4422o6VV22"$J&8`]`&`/P&`&`S`&`&`dghwiJeJKXeX&`&`&`&` KKb/en>YPY%'8,$j #6 '!&!& 'y" = = ###K#-988E+BX,7,>1616#.#5#C#C.E-DIM&+k/0!B$ )#LL V % 0, ,t 'sZ=X's's'sisuHjI's's'sU_`nUo's's'sttt->F-@G'8F'53C=CaZZ6F?S#8#8Q $/II%<II*0<II 'HII4;HIII #(>V++OOOOOO--////$%%&M>&M&M&MNNN#   #,$))"---'+$*0++B///"ikkN:  !1SSS[_ ```&&x1EFFF" !sWb!s!s!s!sg g g #,$))*HIII'+$*0++B///i);<<W!PnpqArAruvAvAv"9~~3355H&/8&;&Rw(?RO $x/K%1I/6I()Fh(O(O%!,5558FF504-!*d3359*EE504-!'%1CT"J"JDQQ589OPP504-) !,? !::a?::, !MM#(#3 } } }&** "MM#(#3!F!F!F&**!&f!592/K8.T.T+%lD99G8FFF &j$77F9*EEE-2*%ge5G&N&NPTUUf1MeNd1e1e.+0(%geWd&C&CTJJV/H/U/U,,1)%&:C@@90@AU0V0V-04HHH7H 4>O ;48 1%ge5NPT&U&UWZ[[93CEDa3b3b03u7TTT@T =48 1-2* *'%9I4*P*PRVWW&E0445FGGG!%) &&6==a1NO_1`1`.16-#*5)T#B#B#Hb#")9()C)CJ)X550: #-ge=Mt.T.TVZ#[#[!QFPE$8$C$+5(D#A#A#MRYZ_ZfhqRrRr#M;EEL$88< 5 % ','7%W%W%W+/ !.!"!"!"::a?::/515/5 15 2 5 5 '* !MM#(#3!Z!Z!Z&** "MM#(#3!J!J!J&**!  #GIvt$D$D%3$+Iy$$G$G%3$' NN!4!4II!D%iEE #,(H'__.. .12222-E222//+ )D0SSC >>1?9?591"5*CUKK !8<5!!399;;;;(!!! D!77999 $/aaa"&& !N&777*GGG#s**6+26.BBBNN!05+0M0MSZ )9&v&v&v&v&vwww N&888&00#s**5+15-AAAMM!!1oooppp POOOOO"799D!#J ' 64 @ @ hGIWacgDhDh ,),UDSD)9J$U-^^^___!N!1LL LLMMMU-CCCDDDU-BBBCCCU-eeefffU-pppqqqU-ccSWcccdddU-zzz{{{Ni//#s**8+480DDFF! )9&|&|&|}}} N&:::#s**';<<+:+6:2GGGGGGFFHH!!1vvvwww 2CBQ/RUBVBV"q">">\qKU-\\\]]]U-LL{LLMMMQT\Y\]`YaYadfYfYfU-MMCRCMMMMotom\m\m\]]]U-BBBCCCOOOOOO"799DU-CCQUCCCDDDU-CCSWCCCDDDU-yyyzzzU-ssstttU-nnnoooU-rrrsss%)JJJ8K480&>>%b$//>FF#6===MM +EEE"" O=(#h-- HHHH%)QQQ=R9=5&SSSSSS'?'? 'L'L 99$&&&S!,j%& & ! ! $/[[(1[[["&&  J!,i !OP( q #y{{^; %%O;OOOOO")__5  NN0022 !&!;!;I!F!FQ--//" $E:yAA z9== ;;?J#R#;[#;#;#;#;PR  !1QQT_QQbmQQr|QOQQY] ^^^ !1aaYaaY_aaim nnn !1LLULLTX YYY !1RR.RRZ^ ___i;#4#4 ' 64 @ @I9P9P$n*7$5:Q::6"604,x==<777\;Q;Q!..!Bl V!B!B(/ A!B!B!B!JqMMM?C<!EEEE#-"3"-"*8##%u'6$HHHH.$(!&00")^-FFF/G05,%,Iz4$H$H  )3GIy$???.2"4N3M$--2-D44404 22(1.; $L!9 %/!'2   %)II% 3&&"5>377'75>IIMM +www""MM +www""MM +sss""MM +xxx""MM +jjj"" (.(A-(+.FFF )9'Z'ZYq'Z'Z'Zbf ggg )9'N'N'NVZ [[[ )9&|&|Xp&|&|&|}}}..x9MNNN(0).)7&B]u&B&B&B'+&*59  &&(_j~(_(_BZ(_(_(_```#&x==L5:5L5L . 16M662H2,0(8}}|33**+y+y+yTWX`TaTa+y+y+yzzz 1 ;?8 )9&m&m&muy zzz )9'N'N'NVZ [[[ )9&j&j&jkkk..x9MNNN(0).)7%`'+&*59  %)HH(+U!&!9J(7G%MY$W$WM$0$'q-"*<#=#==E: $/mm8@Emm1>lmm`glmmm#' &-1,/2JJJ!MMU-=+B+B]u+B+B+BJNMOOO!MMU-=+R+R+RZ^M___#MU-=+E+E`x+E+E+EFFF!228=QRRR,4-2-;*D_w*D*D*D+/*.9=$$<@8$B)#L#LL'.uj"'E'E'K&R&R&T&TO#*5*b#A#A#GR"O"OPS"T"T"Z"Z"\"\K'+DD&113(,J(D0J< I0 $ ? w(>(>". )9'A'A\c'A'A'At{'A'A'A'AIM NNNN4 ?") $/]]9@\]]]"&&#6g">">V7W#4#4"//"'++2%*^$+E9b$A$A%*^ 0#:/@AA 9=J6 EI , H1HEEJA )9'Q'Qnu'Q'Q'QF'Q'Q'Q'QY] ^^^^ )9'I'I'IQU VVV(A-(+.FFF )9&}&}Yq&}&}&}FJ KKK )9'N'N'NVZ [[[ )9'A'A\t'A'A'ABBB..x9MNNN(0).)7%[s%%%'+&*59  &&(gm(g(g(grF(g(gIa(g(g(ghhh#&x==L5:5L5L . 16M662H2,0(8}}|33w37WCTCTx==<77!../}\/}/}X[\dXeXe/}/}/}~~~ 1 ;?8 )9&s&s&s{ AAA )9'}'}'}EI JJJ )9'G'GTa'G'G'G'GHHH..x9MNNN(0).)7%t%t%t%t%t'+&*59  ,y:y*ABB @&!$68L#M @'y#,???*. &00  * :: &-*5*2*5*;*<*<*=6 #221 "#<&&'p;'p'p'pqqq3355!&' /0,5:2 !-55&/KS\6&&CCC 55i@@CCMMU%5"u"u\g"u"u"u~BMCCCMMU%5"e"e"e"e]c"e"emqMrrrMMU%5"P"P"P"PX\M]]]!)Z->.BX-X-X$(EEE+Y\J\J\(N:: % 1A/O/O/OW[ !\!\!\ % 1A/C/C/CKO !P!P!P % 1A/C/C/CKO !P!P!P % 1A.v.v.vC !D!D!D!D % 1A.{.{.{DH !I!I!I % 1A/[/[/[cg !h!h!h!h!MMU-=*x*x*xAEMFFF!MMU-=*l*l*ltxMyyy!MMU-=*s*sjp*s*s*s{MAAA4SZZQQP % 1A/C/C/CKO !P!P!P )9&q&q&qy} ~~~MU%5"^"^S\"^"^___ #c))}u/D/DLHYHY\^H^H^ $/PPP"&& ..x9MNNN*.$,%3%*"&!$Y +-- 6!%:^:^!{ ;_;;!6:2&'  &&'mk'm'm'mnnn3355!&' /0,5:2 %*%?%? %J%JN&o**+o[+o+o_m+o+opppp**+m;+m+m]k+m+mnnnMMU%5"\"\N"\"\dhMiii$I}dCCC    9   $' $/;;;#' & $/)))#' &Mj(+~!63|+<+<>R>R "-55&/Fi6**85IJJJ&f{&f&fVd&f&fO&'F+:$,%3%*"&!/  $ "%$+GIz4,P,PR[]a$b$bM$%)F)F%"/"3"3M"B"B"fmFWFWXeFfFf"%%/25>>3/G/G $-z#:%%% $%,8{LL>N{gjvz>{>{>{ "u&&(Ey(E(E(Ealopap(E(Es~(E(E(EFFFF&&'s)'s's'sT_'s'sbm's's'stttJ--// !IKK)3 )*&ikkI--1  )9&n&n&nvz {{{..x9MNNN--////Kmx/K/K|G/K/K/K(0)7).+/   JsOOO+a/*-3q88--IKII+II"9ty{{#:;;III#ikkI--g$g ]K''p<   =   +  a N  " ) ) + + + 1 K/4 ,  + /4.>H%**DK $;a$?@F14VU1C1CE .    C  U%aaa b b b  " "8-A B B B i --//J " ~!5559>9R!"5666xUUCTUUJ * &4M !(4ZHYHacf=g=g4'/c4((9030C0C0pswwyZ\G]G]0paeakloapap%--T** 9E #<<%dC00<!LL....'d33<8H8HF8R8R!LL&")=)=>>>>'d33<$!LLT&\):):;;;04 %0@0@%--03C%- JJJJJJ(/0A".#0-#&l"3"3"3$+8Wd#C#C#C&X CCHMMM '8&7!"-0,@,@,@#$/22G.H.H.H%(    !( a1A a(aMMU%5"b"bGXG`"b"bccccMMU%5#`#`GXG`aebeaeGf#`qtvGvOrPrPSVrVrVhmhm\^#`#`aaa") e.J /7==??  fCR%'' ALS[..t44Q7<%%%""J " $/ZZ.;ZZZ"&& 783556GHHH..x9MNNN.2(0)7).'+%T   //14//+B!{/=@@&**d*d*d*d9J*d*d*d&d&d%Ec%E%E%E!, /l $OO(.(* (802+6 -- !/0+05/M/M%000!,05/L/L%000!,!& > >?PR_ ` ` 18>B AE$H$H$V$VA5AE2 +4555++'),,,,,"3">,,,))%BSE>(AU-H-H-J-JA4811??AAA % 9 9, G G M M O O A!MM*?*?*?@@@ % ("8B<66(! (()<==( LLNNN#'L ("8B<66(! (()<==( 567E334E027. ...55mDDD.33D9999$))*;XGXZhiii6B$BH(8%%*%N%Nx%X%XN&&]8J]]hm]]OO[^$T$TUUU /0+-1) VU8I8TUUU  000*11333 $6 1A55 $/#ALL $A  (;t$$$L, 01L1L\1Z1Z 0%%&CDDD5:5L5L .&+&>&Q 16M662H2,0(+3'''111"3!:!@b-2);;NKK~ 'I2NNTRT&;;%>?P%Q%Q%W%W%Y%Y  : OO **0*48<5 'u.H$OOH GE3Y[`$a$a ,I) $uvvv**+z{{{9=6EJB784 */)B)B8)L)L)R)R)T)T8<5'***!)"##***''O,0 =*0bM,,(($! '/I5 Q Q$!!5$! :>6:>6EJB 5**2&+%C%CDUWd%e%e 09 9-BF #>?  333 $*!L:>))!'+ 1;EE0"#46I4PP0"#46I4PP00 ''O '!5+JQ+N+N771<77 <!; **E % ?EEE',&D&D-|'' <@ $78  4442:///999 (-'@'@&((egg$L(A!;q@'$ !_ !@R !X]XtwxXxXx449444!8%+ **B % <BBB!$%(=%J!8%+!N  **@!7799 %;O%P%PNCCHMMM$)$B$BCTVc$d$dM/8M), AEM"<=OOM222%LOP^L_L_beLeLeN4C4,@5,H,Hky),-> **K 3"8%+!N **M!J!J!P!P!R!R!::;Lm\\  #"8B<66 #! (()<== # $B<++,GHH # $B<++,FGG #LLNNN #"8B<66 #! (()<== # $B<++,GHH # $B<++,FGG # ***$S=$S$S$S!'{%%&y>&y&y&yzzz1 1 1 ^N^^VYZ[V\V\^^I ((Y(())))Z( ( ( ( Y''''' ( LL;^VZL [ [ [ S]]Q.B77  sm!#t,,E776??f,,776??k11cggl6K6K1$$!)#'((!3$$$L ",/ 5 5!GB)=)=Gxd8<77(.(+ (P(PQS(T(T024+OI+O+O ''G %OOG444!5!999$R3B3$R$R$R!!_T]!_!_ P PQQQ :9999W1 Eb E0 0 0U5K5UXY5Y5Y^c^v5Yjc%...  ! +q 0 0 _n^^uG[^^^  ,. , ,5CW , , ,       ,,,%J^,,,   55hOOz~~&:;;   **"#/) .))161E))).+    ) .%2F    - !  d*T~@T/TI 8%D\%R%RT]^^^ !!"3444  33H=== 8%9::: 2:CXb\%%f---tNO8$$  Bvvf~~,, 1E1E,,'OJtAw55O&*2hll:r&B&B&F&Fv&N&NO(6<N###1I272HO5)..aL6;6LS%(22RSK D 5;8Lk.) "F J  L ) *  )      I+ ++++"OkO Oe%BDIIORG O5@@BB OCCGLLO%3%:%:%<%!" E:#$4"<2%e&>@TVWXX]\]#>001F4 *6#AMMOO{0022O2"1$)E!?u/?&+&>"# "E" #a''(E,GGG%"888 $#$  ((3%)k/DH]   * *"&x..33 +         D  >BBBBBB '#+UJ55;       >>>7========> Ms4A(( A54A5)G22 G?>G?'8S S-,S-0U U5U00U5%V&& W0WW Da b 'bb 89e22 e?>e? 5g gg,C-o p $pp 0t tt"vv vEAAFFA AG&G%AG&R'A=AU T%"AU U AU"U AU"U!AU"U&A4BnWD A[)[(Bn[) A[6[3Bn[5A[6[6XBns;F BnzAzzBnzAz/z,Bnz.Az/z/EBn@ABnA+C>BnE*A=BnG)J9BnR#CBnU&A0BnW:BnXABnY(A:Bn[#?Bn\#JBnf=B&Bi$i#Bni$ Bji.#BjjBnjBjjB3BnmBm!m Bnm! Bm.m+Bnm-Bm.m.BnnBD~p, D~p6FD~ w K+D~ B>D~ C?CDDD~ D CDD D~ D CDDC)D~ G=D D~ LAD~ M(A#D~ O CO(O'D~ O( CO5O2D~ O4CO5O58D~ P3A+D~ R$AD~ TD~ T>CUUD~ U CU"UD~ U!CU"U"DD~ ZA#D~ [.G3D~ c'D~ dCd!d D~ d! Ced+Cee D~ eCeeAD~ fM"D~ tD~tED~ yB+D~ | )D~ |7A-C~%~$D~ ~% C~2~/D~ ~1C~2~2D~ ~?ED~ I&D~I,DD~ N D~ND~ NID~ W1D~W7CD~ Z>B D~ ]D~] DD~ a'K>D~ m%D~m+'D~ n4D~ oE$D~ t6D~tD~ ~ D~@8GFjHCEK'K&FjK' EK4K1FjK3EK4K4D#FjPEP2P1FjP2 EP?P<FjP>EP?P?FjQ%EQ,Q+FjQ, EQ9Q6FjQ8EQ9Q9A;FjS6A0FjU'LFja0&FjbHA5Fjv5CFjzHFjB5FC C FjC FCCFjCFCCBFjE"C1FjICFjLB!FjOD FjSC2FjWB$FjY*B7Fj\#DFjaB>FjdFFjj Frj!Frj9FkkFrk.Flk=Frk?FllF FrrFru8AFww*FxxFx@A$GA,A, GB"A7GBBGB"B*AGDD GD6DGD1D1GD6D>AGFF GF1F GF,F,GF1N-(GOO GO#O"GO#O'5GPP GQ P'GQQGQ r)NNNNN)r;r<r=r<r>r?r@r<rArBrCrDrErF)S__doc__ __future__rrrrorr rOrrr}typingrrrrr;r rtr agent.codex_responses_adapterr agent.displayr agent.error_classifierrragent.iteration_budgetragent.memory_managerragent.message_sanitizationrrrrrrrrragent.model_metadatarrrrrr rr!r"r#r$agent.process_bootstrapr%agent.prompt_cachingr&agent.retry_utilsr'agent.trajectoryr(agent.usage_pricingr)r*r9r,rrwr.r?r0rxr2utilsr3r4rrrr9r__all__r r:r8rs; #"""""   ,,,,,,,,,,,,333333333333IIIIII''''''EEEEEEEE222222;;;;;;                       877777>>>>>>......666666DDDDDDDD;;;;;;......;;;;;;;;;;;;88888888  8 $ $15*.*.Y=Y=Y=Y=Y=zz  r: