+ Wj aR[tU0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t H t ^RIHt^RIHt^RIHtHt^RIHtHtHtHtRsRtRsRsR R lt] P@R 8Xd]!4'd^R I!H"t#M^R I H#t#RtM^R I H#t#] PH!4t%Rt&Rt'Rs(RRlt)Rt*!RR4t+RRlt,RRlt-Rs.] P^!4t0RRlt1RRlt2R\t3RRlt4R R!lt5R"R#lt6R$R%lt7]7!4!R&R']Pp4t9R(R]R)R^R*R_R+R`R,RaR-Rb/t:R.R/lt;R0R1ltR<R=lt?!R>R?]#4t@R@RAltARBtB!RCRD]P4tDRsE]^kRsF]^k.tG]^kRsH] P^!4tI!RERF] 4tJRGRHltKRIRJltLRKRLltMRMRNltNRcRORPlltORQRRltPRSRTltQRURVltRRWR/RXRYlltSRZtTR#)da`Centralized logging setup for Hermes Agent. Log files: agent.log (INFO+, everything), errors.log (WARNING+), gateway.log (INFO+, gateway components; ``mode="gateway"``), gui.log (INFO+, dashboard/TUI-gateway; ``mode="gui"``). All are rotating files driven through one async queue and formatted with ``RedactingFormatter`` so secrets never reach disk. N) QueueHandler QueueListener)Path) monotonic)OptionalSequence)get_config_pathget_hermes_homemkdir_under_hermes_homenamed_profile_is_deletedFc$V^8dQhR\/#return)bool)formats"BC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_logging.py __annotate__r&s""D"c\PR8wdR#^RIp^RIpTPRR7wr4\P!TR4;_uu_4pTPYPP4TPT4RRR4\P!T4R# \dp\ T4sRp?R#Rp?ii;i +'giLM;i \d@p\ T4sRp?\P!T4R# \dR#i;iRp?ii;i \dR#i;i \P!T4i \dii;i;i)uReturn True when portalocker can actually take a lock on this box. concurrent-log-handler locks every write through portalocker, which on Windows instantiates Win32Locker and imports pywintypes. Bundled payloads have shipped with that import broken (the venv's .pth files were never processed), and portalocker 3.x gives no msvcrt fallback — every emit then dies with the ImportError, CLH retries 20x, and the suppressed "Cannot acquire lock" RuntimeError below hides it completely. Probe a scratch file once at import so we can fall back to stdlib rotation instead of silently dropping every record. No-op (True) off Windows, where stdlib is in use. win32TNFzhermes-portalocker-)prefixzr+b)sysplatform portalockertempfile Exceptionrepr_WINDOWS_CLH_FALLBACK_REASONmkstemposfdopenlockLOCK_EXunlockunlinkOSError)rrexcfdpathstreams r_portalocker_prober,&s) ||w'<=HB  YYr5 ! !V   V%8%8 9   v &"  IIdO ! '+Cy$ " ! '+Cy$  IIdO           IIdO   sB#C-CC D'# C. B??C C CD9C D$% D0D95D DDD$$D9' D65D69E#;EE# E E#E  E#r)ConcurrentRotatingFileHandler)RotatingFileHandlerTz>%(asctime)s %(levelname)s%(session_tag)s %(name)s: %(message)szC%(asctime)s - %(name)s - %(levelname)s%(session_tag)s - %(message)scV^8dQhRR/#rrN)rs"rrrts++4+rc`\PpVe V\JdR#\VRR4RJdVsR#\VRR4pVfR#\P !\ \4;_uu_4VP4'g V!RR7VsRRR4R# +'giR#;i)uBest-effort line buffering for a piped stdout (#92281). Python block-buffers stdout when it isn't a TTY, so an agent loop driving ``print()`` into a supervisor's pipe delivers its output in large delayed bursts — a headless run looks stalled for minutes while the work is actually progressing (only stderr, which we already give ``line_buffering=True`` in ``_safe_stderr()``, shows up on time). Reconfigure the interpreter's own stdout for line buffering when it is piped; interactive TTY stdout is already line-buffered. ACP reaches this too (its AIAgent calls ``setup_logging``) with stdout as its protocol channel — harmless, since line buffering only adds flushes at newlines. Nline_bufferingFT reconfigure)r3) rstdout_line_buffered_stdoutgetattr contextlibsuppressr' ValueErrorisatty)r+r4s r_line_buffer_piped_stdoutr<tsZZF ~#88v'/47 &&-6K   Wj 1 1}} t ,$* ! 2 1 1 1s 0"B B- c"\Pp\VRR4;'gRpVP4P RR4R 9dV#\ P !VPRRRR7pR VnV# \dTu#i;i) zReturn a stderr stream that tolerates Unicode on all platforms. Wraps ``sys.stderr`` with ``errors='replace'`` so un-encodable characters become ``?`` instead of crashing the process. encodingNutf-8-r replaceT)r>errorsr3cR#Nr1r1rr_safe_stderr..sr)utf8utf8surrogateescape) rstderrr7lowerrAio TextIOWrapperbuffercloser)r+r>wrappeds r _safe_stderrrPs ZZFvz40;;GH~~R(,KK ""6==79eij$   s-A>> B Bc6a]tRt^toRtRtRtRtRtVt R#)_RedactingStdiozText stream proxy that redacts each write: a detached gateway's stdout/stderr IS a persisted log (``logs/gateway-stdio.log``), and agent status lines (provider error echoes) reach it through ``print``, never through ``RedactingFormatter``.cWnR#rD_stream)selfr+s&&r__init___RedactingStdio.__init__s rc^RIHpVPP\ V\ 4'd V!V44#T4#))redact_sensitive_text) agent.redactr[rUwrite isinstancestr)rVtextr[s&& rr]_RedactingStdio.writes66||!!DRUAVAV"7"=aa\`aarc.\VPV4#rD)r7rU)rVnames&&r __getattr___RedactingStdio.__getattr__st||T**rrTN) __name__ __module__ __qualname____firstlineno____doc__rWr]rd__static_attributes____classdictcell__ __classdict__s@rrRrRs Ib++rrRcV^8dQhRR/#r0r1)rs"rrrs88t8rcRFKp\\V4pVfK\V\4'dK1\ \V\V44KM R#)zORoute a detached process's stdout/stderr through secret redaction (idempotent).N)r5rI)r7rr^rRsetattr)rcr+s rredact_detached_stdiorrs;$d#  j&I&I Cv6 7%rc>V^8dQhR\R,R\/#rr(Nr BaseExceptionr)rs"rrrs  1E $ rc\PR8H;'d'\V\4;'dR\ V49#)a True for concurrent-log-handler's Windows lock timeout. Slash-command workers and the gateway share rotating files on Windows Desktop; when another process holds the rollover lock too long CLH raises this RuntimeError, which must not escape into Desktop chat output. rz%Cannot acquire lock after 20 attempts)rrr^ RuntimeErrorr_r(s&r'_is_windows_concurrent_log_lock_timeoutrzsC  @ @ sL ) @ @ 3s3x ?rcV^8dQhRR/#r0r1)rs"rrrsrc\;_uu_4\'d RRR4R#RsRRR4\P!R4P R4R# +'giL7;i)u3Report a suppressed CLH lock timeout exactly once per process. Every emit after the first failure raises the same RuntimeError, so the warning must be one-shot or it would spam errors.log as badly as the stderr noise it replaces. CLH does not chain the underlying cause (the RuntimeError is raised outside the except, from the retry loop's else clause), so the message cannot include it; a constantly repeating timeout means file logging is degraded — the startup portalocker probe in this module should have caught a dead portalocker and fallen back already. NThermes_loggingzconcurrent-log-handler timed out acquiring the cross-process log lock; this and later records were dropped (the Desktop slash-worker surface stays clean, but file logging is degraded).)_windows_lock_timeout_warn_lock_windows_lock_timeout_warnedlogging getLoggerwarningr1rr_warn_windows_lock_timeout_oncersR ) ( ' '  ) ((,$ ) &'// > ) (sAA A( c>V^8dQhR\R,R\/#rtru)rs"rrrsMD$8Trc\V\4;'dVP^8H;'g5\V\4;'dR\ V4P 49#)zHTrue when a file handler lost its backing stream during teardown or I/O.z closed file)r^r'errnor:r_rJrys&r_is_unavailable_log_streamrsQ C ! 4 4cii1n O O sJ ' M MMSX^^=M,MrcV^8dQhRR/#r0r1)rs"rrrs::d:rc\F6p\P!V4P\P4K8 R#)z)Pin noisy third-party loggers at WARNING.N)_NOISY_LOGGERSrrsetLevelWARNING)rcs r_quiet_noisy_loggersrs)$((9rc(V^8dQhR\RR/#)r session_idrN)r_)rs"rrrs--C-D-rcV\nR#)z*Set the session ID for the current thread.N_session_contextr)rs&rset_session_contextrs ",rcV^8dQhRR/#r0r1)rs"rrrs''t'rcR\nR#)z,Clear the session ID for the current thread.Nrr1rrclear_session_contextrs "&rcV^8dQhRR/#r0r1)rs"rrrs999rca\P!4o\SRR4'dR#V3RlpRVn\P!V4R#)aReplace the global LogRecord factory with one that adds ``session_tag``. Unlike a Filter, the record factory runs for EVERY record in the process (propagated and third-party-handled ones included), so ``%(session_tag)s`` never KeyErrors. Idempotent via a marker attribute. _hermes_session_injectorFNc<S!V/VBp\\RR4pV'dRV R2MRVn\\ 4P 44VnV# \d RTnT#i;i)rNz []r )r7r session_tagr_r resolve hermes_homer)argskwargsrecordsidcurrent_factorys*, r_session_record_factory@_install_session_record_factory.._session_record_factorysx $1&1& d;,/r#a[R $!$_%6%>%>%@!AF   $!#F   $s&AA/.A/T)rgetLogRecordFactoryr7rsetLogRecordFactory)rrs @r_install_session_record_factoryrsE113O :EBB 8<4  78rcTaa]tRtRtoRtV3RlV3RlltV3RlRltRtVtV;t #)_ComponentFilteri&zBOnly pass records whose logger name starts with one of *prefixes*.c4<V^8dQhRS[S[,RR/#)rprefixesrN)rr_)rrns"rr_ComponentFilter.__annotate__)s))#)4)rcD<\SV`4\V4VnR#rD)superrWtuple _prefixes)rVr __class__s&&rrW_ComponentFilter.__init__)s xrc:<V^8dQhRS[PRS[/#rrr)r LogRecordr)rrns"rrr-s!66W..646rcLVPPVP4#rD)rc startswithrrVrs&&rfilter_ComponentFilter.filter-s{{%%dnn55r)r) rfrgrhrirjrWrrkrl __classcell__rrns@@rrr&s!L))666rrgatewayagenttoolsclicronguic:V^8dQhR\\,/#r)setr)rs"rrr@s  #d) rc\4p\Fp\V\4'd9VP VP 4VP VP4KQ\V\4'gKiVP \VP4P4PP4K V# \\\3dKi;i)zHomes the queued file handlers already serve: static handlers by their file, routers by their default home plus every profile home they route. Caller holds ``_queue_state_lock``.)r_queued_file_handlersr^_ProfileRoutingFileHandleradd _default_homeupdate_profile_homesr.r baseFilenamerparent TypeErrorr:r')homeshandlers r_known_log_homesr@suE( g9 : : IIg++ , LL// 0 !4 5 5  $w334<<>EELLM ) Lz73  s;ACC! C!c0V^8dQhR\R\/#rhomerrr)rs"rrrPs B B B BrcD\V4P4P4p\ ;_uu_4\4pRRR4X'dY9dR#\.\T4OTN4# \\\ 3dR#i;i +'giLU;i)zRoute *home*'s records to its own files when this process already logs for another home. Enables profile routing for the union of homes (or widens the live routers); False when *home* is the first home seen or is already served.FN) r expanduserrrr:r'_queue_state_lockrenable_profile_log_routingsorted)rresolvedknowns& r_adopt_secondary_homerPs~:((*224   "  H% %&@u &@x&@ AA z7 +  s'A2 B2B  B  B r log_level max_size_mb backup_countmodeforcecV^8dQhR\\,R\\,R\\,R\\,R\\,R\R\/#)rrrrrrrr)rrr_intr)rs"rrr_smNN$N}N# N 3- N 3- N N Nrc vT;'g \4p\VR, 4p\4\V4'dV#\ 4wrp T;'g T;'gRP 4p \ \V \P4p T;'g T ;'g^R,R,p T;'g T ;'g^p^RI H p\P!4pRWVR3R\PR^R3R\PR^R 3R \PR^R 33pVFVwpppppVe VV8wdK\VV, TTTV!\4V'd\\ V,4MRR 7KX \"'dC\$'g7R s\P!R4P'R\(;'gR4\*'d V'gV#VP,\P.8XgVP,V 8dVP1V 4\34R sV#)a Configure the Hermes logging subsystem; returns the ``logs/`` directory. Safe to call multiple times; the second call is a no-op unless *force*. Level and rotation defaults come from config.yaml ``logging.*``. ``mode="gateway"`` adds ``gateway.log`` and ``mode="gui"`` adds ``gui.log``. logsINFOiRedactingFormatterz agent.logNz errors.logz gateway.logrzgui.logr)level max_bytesr formatter log_filterTr}z|concurrent-log-handler unavailable on this Windows install (%s); file logging fell back to stdlib rotation without rollover.zportalocker probe failedi iPi)r r r<r_read_logging_configupperr7rrr\rrr_add_rotating_handler _LOG_FORMATrCOMPONENT_PREFIXES_WINDOWS_CLH_FALLBACK_fallback_warnedrr_logging_initializedrNOTSETrr)rrrrrrrlog_dir cfg_level cfg_max_size cfg_backup level_namerrbackupsrroot handler_specsfilenamelvlsizecount components$$$$$$ r setup_loggingr_s"  + +/+D%dVm4G T""*>*@'IZ22y22F99;J GZ 6E11 11T9D@I--j--AG/    D e6 wDA  oq)D GLL"2Au= M 2?-#tUI  TY%6  h cT(5JS'(:9(EFY] 2?%5%5 *+33 J ( F F,F E zzW^^#tzzE'9 e NrcV^8dQhRR/#r0r1)rs"rrrs;;t;rc^RIHp\P!4p\;QJd&RVP 4F 'gK RM RM!RVP 44'dR#\P !\44pVP\P4VPV!\RR74RVn VPV4VP\P8d VP\P4\4\P!R4P\P 4R#) zCEnable DEBUG-level console logging for ``--verbose`` / ``-v`` mode.rc3<"TFp\VRR4xK R#5i)_hermes_verboseFN)r7).0hs& r (setup_verbose_logging..s GA71' / /sTFNz%H:%M:%S)datefmtz rex-deploy)r\rrranyhandlers StreamHandlerrPrDEBUG setFormatter_LOG_FORMAT_VERBOSEr  addHandlerrrr)rrrs rsetup_verbose_loggingrs/    D s G Gsss G GGG##LN3G W]]# +,?TU"GOOG zzGMM! gmm$ l#,,W\\:rcV^8dQhRR/#r0r1)rs"rrrs  D rc:V!4R# \dR#i;i)u^Call *fn* (a ``close``/``stop`` bound method) swallowing errors — teardown must never raise.N)r)fns&r_quietlyrs      s  caa]tRtRtoRtV3RltRtRV3RlRlltRV3RlRlltV3R lR lt V3R lV3R llt V3R lV3Rllt V3Rlt V3Rlt RtVtV;t#)_ManagedRotatingFileHandleriaRotatingFileHandler with managed-mode perms and external-rotation detection. In managed mode (NixOS) the setgid stateDir needs group-readable files, but ``_open()``/``doRollover()`` honor the umask (0644), so ``chmod 0660`` follows both. A rotating handler also holds an fd: if the file is rotated externally (logrotate, ``mv``) writes silently go to the old inode, so each emit compares the path's inode to the open stream's and reopens on mismatch (the ``WatchedFileHandler`` pattern). c<^RIHpV!4VnRVnRVnRVnRVn\SV` !V/VBVP4R#)rZ) is_managedFN) hermes_cli.configr_managed_unavailable_reported_skip_write_when_dir_missingskipped_missing_dir_never_reopen_after_closerrW_record_stream_stat)rVrrrrs&*, rrW$_ManagedRotatingFileHandler.__init__sQ0"  %*"-2)#( */& $)&)   "rcVP'd%\P!VPR4R#R# \dR#i;i)iN)r r!chmodrr')rVs&r_chmod_if_managed-_ManagedRotatingFileHandler._chmod_if_manageds= === **E2   s!9 AAcH<V^8dQhRS[S[P,RR/#)rstrN)rr! stat_result)rrns"rr(_ManagedRotatingFileHandler.__annotate__s$88hr~~&>8$8rc T;'g!\P!VP4pVPVPuVnVnR# \dRRuTnTnR#i;i)zLSnapshot dev/ino of ``baseFilename`` so emit() can detect external rotation.N)r!statrst_devst_ino _stat_dev _stat_inor'rVr,s&&rr%/_ManagedRotatingFileHandler._record_stream_statsZ 811rwwt001B-/YY *DNDN 8-14 *DNDN 8sAAAA/.A/c<V^8dQhRR/#r0r1)rrns"rrr.s . .$ .rc VPe \VPP4RVnVP4VnTP T4R# \dR#i;i)zClose and reopen ``baseFilename`` (best-effort). On failure the stream is left ``None`` so the next emit bails rather than writing to a stale inode. N)r+rrN_openrr%)rVr-s&&r_reopen_stream*_ManagedRotatingFileHandler._reopen_streams] ;; " T[[&& '  **,DK   -   sA A-,A-c<V^8dQhRR/#r0r1)rrns"rrr.s$$t$rc \P!VP4pTP eTPfTPT4R#TPTP3TP TP38wdTP T4R#R# \dTP 4R#\ dR#i;i)zReopen when ``baseFilename`` was renamed, unlinked, or replaced by another inode. Silent + best-effort: any error falls back to the existing (possibly stale) stream so logging keeps working instead of dying on a stat failure. N) r!r0rFileNotFoundErrorr:r'r3r4r%r1r2r5s& r_reopen_if_externally_rotated9_ManagedRotatingFileHandler._reopen_if_externally_rotateds  **+B >> !T^^%;  $ $R (ii #'G G    #H!     !    s BC7CCCc8<V^8dQhRS[PRR/#rrrNrr)rrns"rrr.s!//7,,//rcl<RVnVP'd\VRR4'dR#VPRJpT;'g*\P P VP4pV'dVP4VPfxV'g V'ghVP'dV\P P\P PVP44'g RVnR#\SV`5V4VPe RVnR#R#)F_closedNT)r#r$r7r+r!r*existsrr?r"isdirdirnameremitr!)rVr had_stream file_existsrs&& rrI _ManagedRotatingFileHandler.emits#(   ) ) )gdIu.M.M [[,  EEBGGNN43D3D$E   . . 0 KK Z{HiHiHi bggood6G6G&HII'+D $   V ;; ").D & #rc8<V^8dQhRS[PRR/#rBrC)rrns"rrr.0s!$$'"3"3$$rc |<aa\P!4^,o\S4'd \4R#\ S4'd`SP 'gRSn\ VV3Rl4SPe \ SPP4RSnR#\SS`)V4R#)aySuppress the known Windows ``concurrent-log-handler`` lock timeout. CLH's ``emit()`` routes that RuntimeError here, so this is the single point to silence it before stdlib prints to stderr (which the Desktop slash-worker captures into chat output). Silencing is not silent: warn once through the logging system so a wedged lock is visible in the logs instead of a black hole. NTcP<\RSP RS R2\4R7#)zhermes_logging: z unavailable (z(); file logging paused until it recovers)file)printrrP)r(rVsrrE9_ManagedRotatingFileHandler.handleError..Bs/&t'8'8&9uM<.\s"ri)r!r0rr'r doRolloverr7chownst_uidst_gidr(st_moder)r%)rVpreviousrs& rr^&_ManagedRotatingFileHandler.doRolloverPs  wwt001H    2y*571<HHT..Q**H,<,)r rrrr_rr)r*rrrrrs&$$$$ r_new_file_handlerrigsWDKK(#$Q<) D I'G U # Nrg@caa]tRtRtoRtV3RlV3RlltV3RlRltV3RlRltV3R lR ltV3R lR lt V3R lRlt V3RlV3Rllt V3RlRlt Rt VtV;t#)rizRoute queued records to the log file for their Hermes home. Used only behind the QueueListener, so its small routing lock never blocks an agent or dashboard event loop. Per-home handlers keep rotation, redaction and managed perms. c:<V^8dQhRS[RS[S[,RR/#)rexisting profile_homesrN)r.rr)rrns"rr'_ProfileRoutingFileHandler.__annotate__s(''!4'Xd^'X\'rc <\SV`VPR7\VP4P 4p\ V4VnW0nVPPP 4Vn VUu0uF*p\V4P4P 4kK, upVn VPVn \VR^4Vn\VR^4Vn/Vn\$P&!4VnRVn/VnVP/VP04VP2FpVP5V4K R#uupi)zDTake over *existing*'s path, level, rotation, formatter and filters.)rrgrhFN)rrWrrrrr__hermes_routed_log_pathrrrrrc _filenamer7 _max_bytes _backup_count_profile_handlers threadingRLock_profile_handlers_lock_router_closed_liveness_checked_atrrfilters addFilter)rVrlrmrrrrs&&& rrW#_ProfileRoutingFileHandler.__init__s x~~.--.668M'/$%__33;;=MZ[]TtDz446>>@][!!(J:$X}a@JL&/oo&7##79! (,,-"**J NN: &+\s0Ec:<V^8dQhRS[PRS[/#r)rrr)rrns"rrrns!w'8'8Trc\VRR4p\V4P4P4pW0P8XgW0P9d VP#VPPV4pVe\4V, \8d$VPV4'd VP#V# \\ \ 3dTPpLi;i)rr )r7rrrrr:r'rrryget _monotonic_PROFILE_LIVENESS_RECHECK_S_release_if_deleted)rVrraw_home candidatelasts&& r_home_for_record+_ProfileRoutingFileHandler._home_for_records6="5 +X113;;=I ** *i?R?R.R%% %((,,Y7 <:<$.2MM'' 22))):w/ +**I +s'C"C%$C%c&<V^8dQhRS[RS[/#rr)rrns"rrrns    rc \4VPV&VP4'd\V4'gR#VP V4R#)z?Release *home* if it was deleted out of band; True when it was.FT)rryis_dirr release_profile)rVrs&&rr._ProfileRoutingFileHandler._release_if_deleteds@*4,!!$' ;;==!9$!?!? T"rc6<V^8dQhRS[RS[S[,/#r)rrr)rrns"rrrns!dx8S/Trc VP;_uu_4VPPV4pRRR4XeV#\VR, VP, VP VP VPVPR7pWP8gVn RVn VP;_uu_4VP;'g%WP8g;'dWP9pV'dRMVPPW4pRRR4W#Jd\VP 4V# +'giEL;i +'giL@;i)zNThe open handler for *home*; ``None`` once the router or that home is retired.NrrrrrT)rwrtrrirqrrrrsrrr"r$rxr setdefaultrrN)rVrrbuiltretireds&& r_handler_for_home,_ProfileRoutingFileHandler._handler_for_homes  ( ( (,,006G)  N " 6MDNN *$**++t~~ .25G5G-G**.'  ( ( ())mmd6H6H.H.l.lTYlYlMlG%d4+A+A+L+LT+YG )   U[[ !+) ( () (s#D?=)E'E>E? E  E# c4<V^8dQhRS[P/#)rrrC)rrns"rrrns  W.. rc VPV4p\V\P4'dTpV'dVP V4V#)aK``Handler.handle`` without this router's own I/O lock: each per-home handler takes its own lock to write, and routing state has ``_profile_handlers_lock``. Holding ``self.lock`` across ``emit`` (which can open a handler, taking ``logging._lock``) inverted the order ``logging.shutdown`` uses (module lock, then handler lock) (T23).)rr^rrrI)rVrrvs&& rhandle!_ProfileRoutingFileHandler.handles> [[  b'++ , ,F IIf  rc8<V^8dQhRS[PRR/#rBrC)rrns"rrrns!%%7,,%%rcVPV4pVPV4pVf7W P8wd'VPVPVP4r2VfR#W P8XdVPV4R#^RIHpHpV!\V44pVPV4V!V4VP'dFVPV4VPVP4;peVPV4R#R#R# T!T4i;i \dTPT4R#i;i)N)reset_hermes_home_overrideset_hermes_home_override) rrrrhermes_constantsrrr_r#rrrT)rVrrrrrtokenfallbacks&& rrI_ProfileRoutingFileHandler.emits %((0D,,T2G4+=+=#= $ 2 2D4J4J4K]K]4^g)))v& ^,SY7E 2v&*51***((. $ 6 6t7I7I JJHWOOF+X+ +51 %   V $ %s=A D $!D D !D2D AD  DD E?Ec<V^8dQhRR/#r0r1)rrns"rrrnstrcH<VP;_uu_4RVn\VPP 44pVPP 4RRR4XFp\ VP4K \SV`4R# +'giL>;i)TN) rwrxlistrtvaluesclearrrNr)rVrrrs& rrN _ProfileRoutingFileHandler.closesq  ( ( ("&D D2299;.us(?rzhermes-log-drainT)targetrcdaemon)rruThreadrjoin)rtrs& @rdrain_log_queuerls> H ?FXaefAGGIFF7OrcFV^8dQhR\\,R\/#)r profile_homer)r_rr)rs"rrrzssTzcrcna\V4P4P4o\ ;_uu_4\pTeTP4Rs\T3Rl\44pTe \4RRR4T# \\\ 3d^#i;i +'giX#;i)azRelease this process's routed log files below a profile before it is removed. The Desktop serve process can route records for several profiles through one ``QueueListener``. On Windows, each routed concurrent log handler keeps its lock file open, so closing only external profile resources still leaves ``logs/.__agent.lock`` and ``logs/.__errors.lock`` unavailable to rmtree. Nc3v<"TF.p\V\4'gKVPS4xK0 R#5irD)r^rr)r rrs& rr /release_profile_log_handlers..s3 0'#=> *G # #D ) )0s99) rrrrr:r'rrrsumrr)rrreleasedrs& @rrelease_profile_log_handlersrzsL!,,.668  "   MMO"O 0     ( *  O z7 +   Os'BAB#B B # B4 c\V^8dQhR\\\,,R\/#)rrmr)rr_rr)rs"rrrs#++hsTz.B+t+rc 6.pVFcp\\V\4'd V^,MT4P4P 4pY19gKRTPT4Ke \V4^8dR#\;_uu_4\'g RRR4R#\Uu.uFp\V\4'gKVNK ppV'dRVF@pVP;_uu_4VPPV4VnRRR4KB RRR4R#\ pVeVP#4Rs.p\F[p \V \$4'd2VP\W44\'V P(4KJVPV 4K] V\R&Ve \+4RRR4R# \ \ \3dEKi;iuupi +'giEK);i +'giR#;i)aMake the queued file logs follow a desktop profile context. ``setup_logging`` binds handlers to one process home; the desktop dashboard's embedded cron ticker may run jobs for every profile, so its static file handlers are replaced with profile routers once the profile list is known. Returns ``True`` when routing is (or already was) enabled; a single-profile caller is left untouched. FNT:NNN)rr^rrrrr:r'rlenrrrrwrunionrrr.rrNr) rmrentryrr routersrr replacementrls & rrrsE  5%(@(@E!HeLWWYaacH  LL "  5zA~  $$  4a3z!E_7`113a "333-4-C-C-I-I%-PG*43#  #   MMO"O -H($788""#=h#NO(""8, . $/a   ( */  :w/   b433   s[AG H$H,G- G-#H2!G2  H*BHG*)G*-H2 H= H H cV^8dQhRR/#r0r1)rs"rrrs   rc\4\;_uu_4\P!4p\ VP 4F)p\ VRR4'gKVPV4K+ \Fp\VP4K \P4Rs RRR4R# +'giR#;i)zETear down the async logging queue + listener (test-isolation helper).rFN) rrrrrrr7 removeHandlerrrrNrr)rr s r_reset_queued_handlersrs    "dmm$Aq/511""1%%'A QWW '##%     s>B3A B33 C rcV^8dQhR\R\R\R\R\PR\\P ,RR/#) rr*rrrrrrN)rrr FormatterrFilter)rs"rrrs_(&(& (& (& (&  (&   (&((& (&rcVP4p\Fp\VRR4V8Xg@\V\4'd-\ \VRR44P4V8XdR#\V\ 4'gKoVPVP8XgKVPPVP8Xg(VPPVP9gKR# \WW#VR7pVeVPV4\U u.uFp \V \ 4'gKV NK p p V 'dv\4p V F9p V PV P4V P!V P4K; \ V\#V 44p \%VP&4T p\)V4R#uup i)zSRegister a queued ``RotatingFileHandler`` for *path*; idempotent per resolved path.rpNrr r)rrr7r^r.rrrqrcrrrrir{rrrrrrNr)r*rrrrrrrlrr rrrouterrouteds&$$$$$ rrrsi||~H) 86 = I x!4 5 5WX~r:;CCEQ  h : ; ;@R@RV^VcVc@c OO " "h&<&< <@V@VZbZqZq@q *  YU^G*%0]/Q:aA[3\qq/G]5F IIf** + LL.. /,GVE]CW%^s G<Gc$^RIHpV!\44pV'gR #VPR/4p\V\4'd3VPR4VPR 4VPR 43#R # \dt^RIHp\4p/pTP 4'dI\TRRR7;_uu_4pT!T4;'g/pRRR4K +'giL;iLi;i \dLi;i) z3Best-effort read of ``logging.*`` from config.yaml.)load_user_config_effective)fast_safe_loadrz utf-8-sig)r>Nrrrr)NNN) hermes_cli.config_effectiverrrutilsrrFopenrr^dict)rcfgr config_pathflog_cfgs rrrs  2 N,_->?C% %'')R( gt $ $KK('++m*DgkkR`Fab b %  2 ,)+KC!!##+s[AAQ(+11rCBAAA$  2    sdBDDADA C> C'C>$D' C8 2C>6D8C>;D=C>>D DDcV^8dQh/^\9d\\P,;R&^\9d\\,;R&^\9d \ ;R&#)rrrr)__conditional_annotations__rrrrr)rs"rrrsXl/.HU&& '.mn0/-(/op! t qr)openaizopenai._base_clienthttpxhttpcoreasynciohpackz hpack.hpackgrpcmodalurllib3zurllib3.connectionpool websocketscharset_normalizer markdown_it)rhermes_pluginszplugins.platformszagent.memory_caller_scope)r run_agent model_tools batch_runner)r) hermes_clir)r)zhermes_cli.web_serverzhermes_cli.pty_bridgezhermes_cli.desktop tui_gatewayuvicorn)g?)Vrrjrr8rrKrr!rrrulogging.handlersrrpathlibrtimerrtypingrrrrr r r rrrrr,rconcurrent_log_handlerr-r.localrrrr6r<rPrRrrrzrLockr~rrrrrrrrrrrrrrrrrirrrrrrrrrrrrrrrrrrrr)rs@rrsQ  8(%  !"\<<7  9 $4??$O [ +>& + + 8  %"+.."2.: - ' 98 !6w~~6"^ B Z  I m   BN"&N $N"& N #' N  NNb;* W#"5W#t,"OOn+/ .+//    NN$ ! !$ ,.  :+\ (&,0(&Vr