+ iD[2Rt^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RI H t ^RI H t H t HtHtHtHtHtHtHtHtHtHt]P0!4t^RIHt^RIHtHtH t ^RI!H"t"0Rmt#Rt$RR lt%R t&R t'RR lt(R Rlt)R# ]dRtL:i;i)zt Hermes Web UI -- SSE streaming engine and agent thread runner. Includes Sprint 10 cancel support via CANCEL_FLAGS. N)Path)parse_reasoning_effort) STREAMS STREAMS_LOCK CANCEL_FLAGS CLI_TOOLSETSLOCKSESSIONS SESSION_DIR_get_session_agent_lock_set_thread_env_clear_thread_envclamp_reasoning_effortresolve_model_provider)AIAgent)Session get_session title_from)set_last_workspacec .pVFup\V\4'gKVP4UUu/uFwr4V\9gKW4bK pppVP R4'gKdVP V4Kw V#uuppi)aReturn a deep copy of messages with only API-safe fields. The webui stores extra metadata on messages (attachments, timestamp, _ts) for display purposes. Some providers (e.g. Z.AI/GLM) reject unknown fields instead of ignoring them, causing HTTP 400 errors on subsequent messages. role) isinstancedictitems_API_SAFE_MSG_KEYSgetappend)messagescleanmsgkv sanitizeds& */home/ubuntu/hermes-webui/api/streaming.py_sanitize_messages_for_apir$*ss E#t$$ &)iikMkdaQ:L5LTQTk M == LL #  LNs BBc Rp\V4p\P!V4pV'dRV'dJ\ \ VR.4;'g.4\ \ VR.4;'g.48dTpMTpM T;'gTpVfR#VR8HpV'dRMRpV'dRMRp RV R V R V 2p V'dV R V R 2, p VP 'dVP R,MRp \V \4'dGV PR 4R8Xd1\V PRR44P4V 8XdR#VP PR RRV R\\P!44/4\VP VP 4VnVP#4\$;_uu_4V\&V&\)\&R4'd\&P*!V4RRR4R# \dRpELi;i \dRpELi;i +'giR#;i)zIAppend a visible assistant error to the session so reloads don't lose it.Nr rate_limitu⏱️u⚠️zRate limit reachedErrorz** z:** z **r assistantcontent timestamp move_to_end)r Exceptionrloadlengetattrrrrrstrstriprinttimertitlesaverr hasattrr.) session_id error_typemessagehintcached persisteds is_rate_limiticonlabelr+lasts &&&& r#_persist_stream_errorrF;s FZ(LL, V wy*b177R 8CPZ\^@_@e@eceTD$$((6"2k"Ac$((S\^`JaFbFhFhFjnuFuJJ 7S% QWW-AGFFH   8] + +   , K   @ s. HH%6H9 H"!H"% H65H69 I c \T;'gR4P4pV'g\T;'g.4#\T;'g.4p\R\ V44R4pV'd;\VP RR4;'gR4P4V8XdV#VP RRRVR\\P!44/4V#)zEEnsure a returned final_response exists in persisted message history.r,c3"TF7p\V\4'gKVPR4R8XgK3VxK9 R#5i)rr*N)rrr).0rs& r# 1_ensure_final_response_message..ss8 +C#t$ ),K)G C+sAA ANr+rr*r-) r4r5listnextreversedrrr6r7)rfinal_response normalizedresultlast_assistants&& r#_ensure_final_response_messagerSks^))r*002J HNN## (..b !F #F+  N#n00B?EE2FLLNR\\  MM :S% McRV R\P!VRR7 R2pVPPVP R44VPP 4R#)z+Write one SSE event to the response stream.zevent: z data: F) ensure_asciiz zutf-8N)jsondumpswfilewriteencodeflush)handlereventdatapayloads&&& r#_sserasMwhtzz$U'K&LDQG MMw/0 MMrTc"aaRaSaT\P!V4oTSTfR#\P!4oR\;_uu_4SR\ V&RRR4VRVT3RloS\ S4p\\V4P4P44Vn W'n \TT;'g\VRR44Vn\!S4pSRP#4'd^SS!RRR/4\%4\;_uu_4\P&!VR4\ P&!VR4RRR4R#^RIHp \V !44p \3\VP4R SV R 7\4;_uu_4\.P0PR 4p \.P0PR 4p \.P0PR4p \.P0PR 4p\VP4\.P0R &R \.P0R &S\.P0R&V 'dV \.P0R &VS3RlpVSV3Rlp\6f \-R4h\9V4wpppRp^RIHpV!VR7pVPR4pV'gVPR4pV'gVPR4p^RI!H"pT!4pTPR/4p\GT\H4'dTPR\J4M\Jp\7TTTTRRTRS\M\TRR4;'gR4TTR7 pRTP R2pR TP R!2pRp\TR"R4p T 'EdTPR#/4p!T!PR$/4p"\GT"\H4'dT T"9dT"T ,p#\GT#\H4'dT#PR%R4;'gT#PR&R4.p$T#PR'4'dT$POR(T#R', 24T#PR)4'dT$POR*T#R), 24R+PQR,T$44pM \T#4pT'dTTn)TPUTT,T\WTPX4STR-7p%\[T%PR.4;'g TPXT%PR/44Tn,\TR0R4p&R1p'T&'dT&S8wdSp(T&p)\\T( R22, p*\\T) R22, p+T)Tn/\`;_uu_4T(\b9d\bP&!T(4\bT)&RRR4T*Pe4'd)T+Pe4'gT*PgT+4Rp'T''g*\TR3R4p,T,'d\T,R4^4^8dRp'T''d SS!R5RR6/4\jPj!4p-TPXF[p.\GT.\H4'gKT.PR74'dK4T.PR84'dKM\mT-4T.R7&K] \oTPXTPp4Tn8\TR9^4;'g^p/\TR:^4;'g^p0\TR;R4p1TPr;'g^T/,Tn9TPt;'g^T0,Tn:T1'd#TPv;'g^T1,Tn;.p2/p3/p4/p5\yTPX4EF?wp6p7T7PR<4R=8XEdzT7PR>R4p8\GT8\z4'd{T8Ftp9\GT9\H4'gKT9PR?4R@8XgK3T9PRAR4p:T9PRBR4T3T:&T9PRC/4T4T:&T6T5T:&Kv T7PRD.4Fp;\GT;\H4'gKT;PRAR4;'gT;PRER4p:T;PRF/4pp>T>PTR44pA\|P~!TA4pB\TBPRL4;'g5XBPRM4;'gXBPRN4;'gXA4RO,pC/pD\GT?\H4'd[\{T?P44RP,F6wpEpF\TF4pGTGRQ,\TG4^x8dRRMR,XDXE&K8 T2PORBT=RSXCRTT:RUX@RVXD/4EKB T2TnBT'd\TPX4Fp7T7PR<4RW8XgK\T7PR>R44pHTPRX4^,P4pITIRY,TH9gXHRY,T9gKzTT7RZ&M TP4^R[I!HGpJTJ!4PR\4'do^R]IHHIpKTK!TP^TPr;'g^TPt;'g^TPvTTPp\TPX4R^7R_T/R`T0RaT1/pL\TR3R4pMTM'dO\XMRb^4;'g^XLRb&\XMRc^4;'g^XLRc&\XMRd^4;'g^XLRd&SS!ReRfTP4R.TPXRDT2/,RgXL/4T f"\.P0P'R R4MT \.P0R &T f"\.P0P'R R4MT \.P0R &T f"\.P0P'RR4MT \.P0R&Tf"\.P0P'R R4MT\.P0R &RRR4\%4\;_uu_4\P&!TR4\ P&!TR4RRR4R# +'giE L;i +'giR#;i \,d%\.P0PR R4p E Li;i \>dp\ART 2RR7Rp?E LRp?ii;i +'giEL;i \hdELi;i \>d/p?ELi;i \>dXARO,pCELi;i \>dELi;i T f"\.P0P'R R4MT \.P0R &T f"\.P0P'R R4MT \.P0R &T f"\.P0P'RR4MT \.P0R&Tf"\.P0P'R R4iT\.P0R &i;i +'giEL1;i \>dpN\ARh\P!4,RR7\TN4pORiTOP49;'g&RjXO9;'gRk\XN4P9pPTP'd&RlpQ\SRmXOTQ4SS!RnRTOR?RmRoTQ/4RpN?NEL\SRNXO4SS!RnRTOR?RN/4RpN?NELRpN?Nii;i +'giR#;i \%4\;_uu_4\P&!TR4\ P&!TR4RRR4i +'gii;i;i)qzIRun agent in background thread, writing SSE events to STREAMS[stream_id].Nc<SP4'd VR9dR#SPW34R# \dR#i;i)cancelN)rderror)is_set put_nowaitr0)r^r_ cancel_eventqs&&r#put!_run_agent_streaming..putsB    U2E%E   LL% '   s6 AAreasoning_effortr,rdr=zCancelled before start)get_active_hermes_home HERMES_HOME1) TERMINAL_CWDHERMES_EXEC_ASKHERMES_SESSION_KEYrnrprqrrc*<VfR#S!RRV/4R#)Ntokentext)rurjs&r#on_token&_run_agent_streaming..on_tokens<Gfd^,rTc </p\V\4'dX\VP44R,F3wrE\ V4qfR,\ V4^x8dRMR,W4&K5 S !RRVRVRV/4^RIHpHpH p V!S 4'dDV ;_uu_4\VPS /44p R R R 4X 'd S !R V 4R #R #R # +'giL';i) :NNNxN...r,toolnamepreviewargs) has_pending_pending_lockNapproval) rrrLrr4r2tools.approvalrrrr) rrr args_snapr r!s2 _has_pendingrrprjr;s &&& r#on_tool%_run_agent_streaming..on_tools dD)) $TZZ\ 22 6 6 VtHs2ws{eXZ4[Y\!7FVT9gvyQRWW ++ j"!=>J*,s "C C- z?AIAgent not available -- check that hermes-agent is on sys.path)resolve_runtime_provider) requestedapi_keyproviderbase_urlz2[webui] WARNING: resolve_runtime_provider failed: T)r\) get_configplatform_toolsetscli) modelrrrplatform quiet_modeenabled_toolsetsfallback_modelr;reasoning_configstream_delta_callbacktool_progress_callbackz [Workspace: z] z#Active workspace at session start: ab Every user message is prefixed with [Workspace: /absolute/path] indicating the workspace the user has selected in the web UI at the time they sent that message. This tag is the single authoritative source of the active workspace and updates with every message. It overrides any prior workspace mentioned in this system prompt, memory, or conversation history. Always use the value from the most recent [Workspace: ...] tag as your default working directory for ALL file operations: write_file, read_file, search_files, terminal workdir, and patch. Never fall back to a hardcoded path when this tag is present. personalityagent personalities system_promptprompttonezTone: stylezStyle:  c38"TFq'gK VxK R#5iNrv)rIrs& r#rJ'_run_agent_streaming..$s7O6aQ6s  ) user_messagesystem_messageconversation_historytask_idpersist_user_messagerrOr;Fz.jsoncontext_compressorcompression_count compressedz4Context auto-compressed to continue the conversationr-_tssession_prompt_tokenssession_completion_tokenssession_estimated_cost_usdrr*r+typetool_useidrinput tool_callscall_idfunction argumentsz{}r~ tool_call_id tool_use_idoutputrQre:NN:NNr{r}snippettidassistant_msg_idxruserz [Attached files::N<N attachments) load_settingssync_to_insights)sync_session_usage)r; input_tokens output_tokensestimated_costrr8 message_countrrrcontext_lengththreshold_tokenslast_prompt_tokensdonesessionusagez[webui] stream error: z rate limit429RateLimitErrorz*Rate limit reached. Try again in a moment.r&apperrorr>r/)Qrr threadingEventrrrr4r expanduserresolve workspacerrr3rlr rfr pop api.profilesrm ImportErrorosenvironr _ENV_LOCKrrhermes_cli.runtime_providerrr0print api.configrrrrrrjoinephemeral_system_promptrun_conversationr$rrSr r;rr existsrenameOSErrorr7r6rr8rrr enumeraterLrWloadsrr2rrNsplitr5r9rapi.state_syncrcompact traceback format_exclowerr__name__rF)Ur;msg_textrr stream_idrrlrA _agent_lockrm _profile_homeold_cwd old_exec_askold_session_keyold_hermes_homerwrresolved_modelresolved_providerresolved_base_urlresolved_api_keyr_rt_e _get_config_cfg_pt _toolsetsr workspace_ctxworkspace_system_msg_personality_prompt_pname _agent_cfg_personalities_pval_partsrQ _agent_sid _compressedold_sidnew_sidold_pathnew_path _compressor_now_mrrrr pending_names pending_argspending_asst_idxmsg_idxmcrrtcfnr_jrasst_idxrawrdrrr r!rr+ base_text_load_settingsrr_cceerr_strrBr>rhrjrisUf&&&&&& @@@r#_run_agent_streamingr(s6 IAy??$L ". Y D.  #$y/446>>@A 3   B B+=r B  .j9     9&>? @ f  \ KK 4 (   Y -\c  > ; 6 89M Q[[))%  YJJNN>2'(9:,JJNN+?@/JJNN=9/'*1;;'7"**^ $*-"**& '-7"**) * *7bjj'D > - +!"cddCYZ_C` @N-/@ $  ]P.9JK#&779#5 ((+ (;%((+ (;% ==D((.3C8B38M8M|4S_I$**(!* $%!7CUWY8Z8`8`^`!a&.'.E&+1;;-s;M5akk]CPP !#' Q t4Fv!XXgr2 !+!Dnd33.8P*62E!%.."'))OR"@"["[EIIhXZD[!\ 99V,,"MMF5=/*BC 99W--"MMGE'N3C*DE.2ii7O67O.O+.1%j+"0C-++*X53%? %K"%- ,F8 :&44!** +,AJ! d;JKjJ6$$&G9E)::&G9E)::& T(*,4LL,A)??$$X__->-> 1# %e-A4H 7;8KQ#ORS#S"&KLU# 99;Djjb$''{0C0CBFFSXMM&)$iB{O!!QWW5AG"5*A1EJJL#E+FJOOaM$U,H$ONnn11\AAN 33!}DAO$%$4$4$9$9^#K JML! ' 3 55=K/i,A!!T**!"A)!T22quuV} 7R&'eeD"o56UU625F c 245EE'24F S 18? 0 5 "# eeL"5)"d33$ ffT2.GG"&&B2GVVJ3!vvfb1&-#%88BFF;,E,M,M#ND34415M#.04L-4;,S16UU6]f,%%/KK1553KC(,,S"5D46> /33CW4 8P/:Am,!. FFH F!#''(:;;A&#$<<%&^^%8%8q&'oo&:&:'('7'7#gg&)!**o$\?MScestE%!5t"**./& 7KT(R5D"**12& }d(K.="**]+_F  \ KK 4 (   Y -\] \ \\]  >JJNN="=M >p ]J2$OW[\\ ]pTT #p )&#%D&"%,"%d),P   ~t D/6"**^,#RZZ^^4Et%L2>"**./& 7KT(R5D"**12& }d(K.="**]+_YYb C ')*>*>*@@Ma&% 7ss5G;KssO_cghicjcscsOs ?D !*lGT J  7    "*gw ?  YA B B!C&\\  \ KK 4 (   Y -\\\s x%BA@/x9 y 0A@C$441|&Ay?'y?8D6|/*|1| A|A|'A=|$)z( |+|z< |0|A||.|A ||)"| !|.||B |'|?B | 7|'{*{1|;|)|4| ,|9A |A {"{"({"6B |+|A|&|!{="%{={=3{=0|||56|+C!4 A@,/AC% x6 9 y +y<8A@;y<<A@? z% z | z%%|( z9 3 |< { | {  | { |{ |"{: 6|9{: :|= | | |  |C"1144 A@ ?A@@AC.@A@@ AC@AACA, ACB ACB,AC.B2ACC AC.CACCAC.C AC+ C.AED/AD? D6 AED? AE E AEc0V^8dQhR\R\/#)rreturn)r4bool)formats"r# __annotate__r.sSTrTcn\;_uu_4V\9d RRR4R#\P!V4pV'dVP 4\P!V4pV'dVP RRR/34RRR4R# \ dLi;i +'giR#;i)zISignal an in-flight stream to cancel. Returns True if the stream existed.NFrdr=zCancelled by userT)rrrrsetrgr0)rflagris& r# cancel_streamr2s  G #  *  HHJ KK "   h4G(HIJ      s4 B#B#-B#3B B B#B  B## B4 >rrr+refusalrrr)Nr,)*__doc__rWrqueuerr7rpathlibrhermes_constantsrrrrrrrr r r r r rrLockr run_agentrr api.modelsrrr api.workspacerrr$rFrSrar(r2rvrTr#r<s  3 NN  !87, Z"--`2X.D ]GsB BB