+ jHj!Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t ^RI Ht^RIHtHtHtRtRt^Nt]P,!R 4tR tR R ltR RltRRltRRltRRltRRltRRltRRlt R&RRllt!R&RRllt"RR lt#R!R"lt$R&R#R$llt%]&R%8Xd]PN!]%!44R#R#)'zQRun a child process while prefixing each stdout and stderr line with a timestamp.) annotationsN)Mapping)datetime)Path)BinaryIOSequenceTextIOz--external-supervisorHERMES_LAUNCHD_LABELz2^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2},\d{3}(?:\s|$)g@cV^8dQhRR/#)returnstr)formats"@/home/ubuntu/.hermes/hermes-agent/hermes_cli/stderr_timestamp.py __annotate__rs@@3@cX\P!4PR4R,#)zfLocal time in logging.Formatter's default ``%(asctime)s`` shape, which ``hermes logs --since`` parses.z%Y-%m-%d %H:%M:%S,%f:NN)rnowstrftimerrr timestamprs <<> " "#9 :3 ??rc V^8dQhRRRR/#)r liner r r)rs"rrr"s##S#S#rcVPR4p\PV4'dRM \4 R2pV V R2#)zZ*line* with a leading :func:`timestamp` (kept as-is if it already has one) and one ``\n``.z   )rstrip_TIMESTAMP_PREFIXmatchr)rrenderedprefixs& r stamp_liner#"sA{{6"H$**844RY[M:KFXhZr ""rc$V^8dQhRRRRRR/#)r log_filerrr r Noner)rs"rrr)s!fCDrcZVP\V44VP4R#N)writer#flush)r%rs&&r_write_timestamped_liner+)s NN:d#$ NNrc V^8dQhRRRR/#)r log_pathrr rr)rs"rrr.s====rcdVPPRRR7VPRR^R7#)T)parentsexist_okautf-8)encoding buffering)parentmkdiropen)r-s&r _open_logr8.s. OO$6 ==w!= <.__annotate__Bs!frcP<SPV4R# \dR#i;ir() send_signalProcessLookupError)rPrRrMs&&r_forward,_install_signal_forwarders.._forwardBs(    V $!   s  %%SIGHUPNSIGUSR1SIGUSR2) signalSIGTERMSIGINTgetattr getsignalOSError RuntimeError ValueErrorpop)rMrXprevious forwardedrPsf r_install_signal_forwardersrhAs #%H  $' 4( 4( I   +#)#3#3F#;  f/  O\:6 + VT* +s).B(C C c V^8dQhRRRR/#)r command Sequence[str]r boolr)rs"rrr`s Z Z Z4 Zrc^RIHp\T!RP RT4444# \dR#i;i)zTrue for Hermes ``gateway run`` argv this wrapper is allowed to upgrade. The wrapper is generic. Only historical/current Hermes gateway shapes get ``--external- supervisor``; an arbitrary launchd child must not be marked as gateway-supervised (#87005). )looks_like_gateway_command_lineFrc38"TFp\V4xK R#5ir()r ).0parts& r ._is_hermes_gateway_run_argv..js8WwtTws)gateway.statusrn Exceptionrljoin)rjrns& r_is_hermes_gateway_run_argvrw`s@ B /8Ww8W0WX YY s / >>c V^8dQhRRRR/#)r environMapping[str, str] | Noner zdict[str, str]r)rs"rrrms&>.rcVf\PMTpR\3FWp\VP VR4;'gR4P 4pVP R4'gKO\V/u# /#)u@Env vars that carry this wrapper's launchd identity to the grandchild. launchd stamps ``XPC_SERVICE_NAME=`` only on this wrapper (its direct child; an interactive shell has none, the grandchild sees ``XPC_SERVICE_NAME=0``). Re-exporting the label lets the gateway resolve its job without it (the stop-drain cap reading the live ``ExitTimeOut``, the exit-75 restart route, the control-socket supervisor declaration — all via ``gateway.restart.launchd_job_label``). Only ``ai.hermes.*`` labels are exported; app-coalition labels are meaningless as a job identity. XPC_SERVICE_NAMErz ai.hermes)osry_LAUNCHD_LABEL_ENVr getstrip startswith)ryenvvariablelabels& r_child_launchd_label_envrmsl "**WC');<CGGHb)//R0668   K ( (&. .= Irc$V^8dQhRRRRRR/#)r rjrkryrzr z list[str]r)rs"rrrs#  M `` only on this wrapper (its direct child; an interactive shell has none, the grandchild sees ``XPC_SERVICE_NAME=0``). Newly generated plists put ``--external-supervisor`` on the inner ``gateway run`` so ``hermes update`` can see the flag on the live process argv. r|r0)r r}ryrrEXTERNAL_SUPERVISOR_FLAGrwappend)rjryrqargvr xpc_services&& r_prepare_child_commandrs~#* *'$CI'D *"**WCcgg0"56<<>Kt+ s@RWrswWxWx ,- K +sBc$V^8dQhRRRRRR/#)r rjrk returncoderQr r)rs"rrrs"  m  QT rctV^8d^\V4,#V\8Xd\V4'd^#V#)aExit status the launchd wrapper reports for *returncode* from *command*. Signal deaths stay 128+N. Gateway EX_CONFIG (78) becomes 0 so ``KeepAlive.SuccessfulExit=false`` parks the job instead of crash-looping; a non-gateway child that happens to exit 78 is left alone. )abs_GATEWAY_FATAL_CONFIG_EXIT_CODErw)rjrs&&r _child_returncode_for_supervisorrs8A~S_$$449TU\9]9] rc V^8dQhRRRR/#)r rSequence[str] | Noner zargparse.Namespacer)rs"rrrs  * /A rc\P!RR7pVPRR\R7VPR\PR7VP V4pVP 'd1VP ^,R8XdVP R,VnVP 'gVPR 4V#) zYRun a command, timestamp each stderr line into a log file and each stdout line to stdout.) descriptionz --error-logT)requiredtyperj)nargsz--:rGNNzmissing command after --)argparseArgumentParser add_argumentr REMAINDER parse_argsrjerror)rparserargss& r _parse_argsrs  $ $oF  4@  ););<   T "D ||| Q4/||B' <<< /0 Krc V^8dQhRRRR/#)r rrr rQr)rs"rrrsFF#FsFrc<\V4pVPp\P!\ VP 4\P \P /\PC\4CR7pTPeTPfQh\P !\"TP3RR7pTP%4\'T4p\)TPT4TP+4pTP-\.4TPP14TP34Fwr\4P4!Y4K \7TP T4# \dKp\T4;_uu_4p\TRT 24RRR4M +'giM;iRp?^#Rp?ii;i TPP14TP34Fwr\4P4!Y4K i;i))rEr:rz,failed to start stderr-timestamped command: NT)targetrdaemon)r error_log subprocessPopenrrjPIPEr}ryrrbr8r+rEr: threadingThreadrKstartrhrCwaitrv_STDOUT_DRAIN_TIMEOUT_Scloseitemsr]r) rrr-rMexcr% stdout_pumpprevious_handlersrrPhandlers & rmainrs t D^^H  "4<< 0????<2::> >""*Fdkk^dhiK248 +$T[[(;YY[ 01 0668OF MM& * 9 +DLL* EE'  x H #H0\]`\a.b c!  0668OF MM& * 9s=A#E8;G8 G GF/& G/ F? :GG A H__main__r()(__doc__ __future__rrr}rer]rsysrcollections.abcrrpathlibrtypingrrrrr~rcompilerrrr#r+r8rCrKrhrwrrrrr__name__exitrrrrsW"  #--2+#%JJTU@ # = Z U> Z$   FB zHHTVr