+ iGRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ]P!4R8Ht ^RI HtHt^RIHtHt^RIHtHtHtHt^RIHt]P4!]4t]!4R, tRtR t^@t ]!R R 44t!!R R 4t"]"!4t#^RI$H%t%RRRRRRRRRRRR.R,ORR/RRRRR/RRRRR/RRR RR!R"^/R#RR RR$/R%RR RR&R"^//R'R.//t&R(t']%PP!RR)]&]'R*R+7R#)-a Process Registry -- In-memory registry for managed background processes. Tracks processes spawned via terminal(background=true), providing: - Output buffering (rolling 200KB window) - Status polling and log retrieval - Blocking wait with interrupt support - Process killing - Crash recovery via JSON checkpoint file - Session-scoped tracking for gateway reset protection Background processes execute THROUGH the environment interface -- nothing runs on the host machine unless TERMINAL_ENV=local. For Docker, Singularity, Modal, Daytona, and SSH backends, the command runs inside the sandbox. Usage: from tools.process_registry import process_registry # Spawn a background process (called from terminal_tool) session = process_registry.spawn(env, "pytest -v", task_id="task_123") # Poll for status result = process_registry.poll(session.id) # Block until done result = process_registry.wait(session.id, timeout=300) # Kill it process_registry.kill(session.id) NWindows) _find_shell_sanitize_subprocess_env) dataclassfield)AnyDictListOptional)get_hermes_homezprocesses.jsoni@ ica]tRt^>toRtRtRtRtRtRt Rt Rt Rt Rt Rt]tRtRtRtRt^t]!]P0R7t]!RRR7t]!RRR7tV3RltR tVtR#) ProcessSessionz3A tracked background process with output buffering.NgF)default_factory)defaultreprc<V^8dQh/S[;R&S[;R&S[;R&S[;R&S[S[,;R&S[S[P,;R&S[;R&S[S[,;R&S[;R &S[;R &S[S[,;R &S[;R &S[;R &S[;R&S[;R&S[;R&S[;R&S[;R&S[P;R&S[S[P,;R&S[;R&#)idcommandtask_id session_keypidprocessenv_refcwd started_atexited exit_code output_buffermax_output_charsdetachedwatcher_platformwatcher_chat_idwatcher_thread_idwatcher_interval_lock_reader_thread_pty) strr int subprocessPopenrfloatbool threadingLockThread)format __classdict__s"3/home/ubuntu/hermes-agent/tools/process_registry.py __annotate__ProcessSession.__annotate__>s: GL      #j&& '. # }#, !$%&'()*+, >>A-.Y--.P/0 /1)__name__ __module__ __qualname____firstlineno____doc__rrrrrrrrrrMAX_OUTPUT_CHARSr r!r"r#r$r%rr/r0r&r'r(__annotate_func____static_attributes____classdictcell__r3s@r4r r >s=GKC*.GGCJF#IM,HO!)..AE16t%1PNd/D1r7r ca]tRt^YtoRtR.tRt]V3RlRl4tR/V3RlRllt R0V3RlR llt V3R lR lt V3R lR lt V3RlRlt V3RlRltV3RlRltV3RlRltR1V3RlRlltR2V3RlRlltV3RlRltV3RlRltR3V3RlRlltR2V3R lR!lltV3R"lR#ltV3R$lR%ltR2V3R&lR'lltR(tR)tR*tV3R+lR,ltR-tVtR#)4ProcessRegistrya  In-memory registry of running and finished background processes. Thread-safe. Accessed from: - Executor threads (terminal_tool, process tool handlers) - Gateway asyncio loop (watcher tasks, session reset checks) - Cleanup thread (sandbox reaping coordination) cd/Vn/Vn\P!4Vn.VnR#N)_running _finishedr/r0r&pending_watchersselfs&r4__init__ProcessRegistry.__init__ks(35 46^^% 79r7c&<V^8dQhRS[RS[/#)rtextreturn)r))r2r3s"r4r5ProcessRegistry.__annotate__ts    r7c 6aVPR4oS'dp\;QJd-V3Rl\P4F 'gK RM" RM!V3Rl\P44'dSP ^4KwRP S4#)z:Strip shell startup warnings from the beginning of output. c3:<"TFqS^,9xK R#5i)Nr8).0noiseliness& r4 5ProcessRegistry._clean_shell_noise..wsc;b%U1X-;bsTF)splitanyrD_SHELL_NOISE_SUBSTRINGSpopjoin)rOrXs&@r4_clean_shell_noise"ProcessRegistry._clean_shell_noisess\ 4 c?;b;bcc?;b;bccc IIaLyyr7NcD<V^8dQhRS[RS[RS[RS[RS[RS[RS[/#)rrrrrenv_varsuse_ptyrP)r)dictr.r )r2r3s"r4r5rQ}sZnnnn n  n  nn nr7c  \R\P!4PR, 2TTTT;'g\P !4\ P !4R7pV'Ed\'d^RIH pM^RI H p\4p \\PV4p RV R&VPV RV.VPV RR7p V P VnWn\$P&!VP(V3R R VP* 2R 7p WnV P/4VP0;_uu_4VP34WpP4VP*&R R R 4VP74V#\4p \\PV4pRVR&\@PB!V RV.R VPTRR\@PD\@PF\@PD\'dR M\PHR7 pWn%VP Vn\$P&!VPLV3R RVP* 2R 7p WnV P/4VP0;_uu_4VP34WpP4VP*&R R R 4VP74V# +'giELu;i \8d\:P=R 4EL\>d"p \:P=RT 4R p ? ELR p ? ii;i +'giL;i)a? Spawn a background process locally. Only for TERMINAL_ENV=local. Other backends use spawn_via_env(). Args: use_pty: If True, use a pseudo-terminal via ptyprocess for interactive CLI tools (Codex, Claude Code, Python REPL). Falls back to subprocess.Popen if ptyprocess is not installed. proc_N N)rrrrrr) PtyProcess1PYTHONUNBUFFEREDz-lic)renv dimensionsTzproc-pty-reader-targetargsdaemonnameNz3ptyprocess not installed, falling back to pipe modez0PTY spawn failed (%s), falling back to pipe modeutf-8replace) rOrrmencodingerrorsstdoutstderrstdin preexec_fnz proc-reader-)x)'r uuiduuid4hexosgetcwdtime _IS_WINDOWSwinptyrj ptyprocessrrenvironspawnrrr(r/r1_pty_reader_looprr'startr&_prune_if_neededrG_write_checkpoint ImportErrorloggerwarning Exceptionr+r,PIPESTDOUTsetsidr _reader_loop)rKrrrrrcrdsession_PtyProcessCls user_shellpty_envpty_procreaderebg_envprocs&&&&&&& r4 spawn_localProcessRegistry.spawn_local}s&!tzz|'',-.#""ryy{yy{   7& V;CG(] 22::xH.1*+)//1 ( 0 'll ' #))00!+GJJ<8  *0& ZZZ))+07MM'**- &&(!] *"**h?%(!"  ) ??$$//*{t   hh !!$$ |,   "(  ZZZ  ! ! #(/MM'** %  i ZZ VTU VQSTUU VLZsO3 K3?C K3 )K3K3)M K0 * K33 MMM L<<M M cD<V^8dQhRS[RS[RS[RS[RS[RS[RS[/#)rrmrrrrtimeoutrP)rr)r*r )r2r3s"r4r5rQsZEE EE E  E  EE Er7c  \R\P!4PR, 2VVVV\P!4VR7pRVP R2pRVP R2p \ P!V4p RV RV R V R V 2p VPWR 7p V PR R 4P4p V P4F;pVP4pVP4'gK+\V4VnM VP 'gK\&P(!VP*WqW3RRVP 2R7pVVnVP/4VP0;_uu_4VP34WpP4VP &RRR4VP74V# \d#pRTnRTnRT 2TnRp?LRp?ii;i +'giLR;i)a Spawn a background process through a non-local environment backend. For Docker/Singularity/Modal/Daytona/SSH: runs the command inside the sandbox using the environment's execute() interface. We wrap the command to capture the in-sandbox PID and redirect output to a log file inside the sandbox, then poll the log via subsequent execute() calls. This is less capable than local spawn (no live stdout pipe, no stdin), but it ensures the command runs in the correct sandbox context. rgrh)rrrrrrrz/tmp/hermes_bg_z.logz.pidznohup bash -c z > z 2>&1 & echo $! > z && cat routputrTzFailed to start: Nz proc-poller-ro)r r~rrrrshlexquoteexecutegetstrip splitlinesisdigitr*rrrrrr/r1_env_poller_loopr'rr&rrGr)rKrmrrrrrrlog_pathpid_pathquoted_command bg_commandresultrlinerrs&&&&&&& r4 spawn_via_envProcessRegistry.spawn_via_envs(!tzz|'',-.#yy{ %WZZL5$WZZL5W-^,Cz:! (8* 6  <[[[=FZZ"-335F))+zz|<<>>"%d)GK ,~~~%%,,H7#GJJ<0 F &,G " LLN ZZZ  ! ! #(/MM'** %  + <!GN "G &7s$;G ! ! < Zs1A(G?GG)G7 G4G//G47 H c <V^8dQhRS[/#rrr )r2r3s"r4r5rQ6s((N(r7c RpVPPPR4pV'gMV'dVPV4pRpVP;_uu_4V;P V, un\ VP 4VP8d VP VP)RVnRRR4KVPP^R7RVn VPPVnVPV4R# +'giEK);i \d!p\PRT4Rp?LRp?ii;i \d!p\PRT4Rp?LRp?ii;i)z:Background thread: read stdout from a local Popen process.TFNzProcess stdout reader ended: %srz$Process wait timed out or failed: %s)rrxreadr`r&rlenr rrdebugwaitr returncoder_move_to_finished)rKr first_chunkchunkrs&& r4rProcessRegistry._reader_loop6s6  ?..33D9 33E:E"'K]]]))U2)7001G4L4LL070E0EwG_G_F_F`0a-#] D OO  +#OO66 w'#]] ? LL:A > > ?  D LL? C C DsR-D0D0'D0"AD? D0 E D- & D00 E;EE F )FF c2<V^8dQhRS[RS[RS[RS[/#)rrrmrr)r rr))r2r3s"r4r5rQQs-**%*,/*;>*JM*r7c 6VP'Eg\P!^4VPRV R2^ R7pVP RR4pV'dgVP ;_uu_4Wan\VP 4VP8d VP VP)RVnRRR4VPRV R2^R7pVP RR4P4pV'dVP4R ,P4R 8wdVPR V R2^R7p V P RR4P4p \V P4R ,P44Vn R VnVPV4R#EKEKR# +'giEL;i \\3d R Tn LPi;i \ d$R TnR Tn TPT4R#i;i) zBBackground thread: poll a sandbox log file for non-local backends.zcat 2>/dev/nullrrrNzkill -0 $(cat z" 2>/dev/null) 2>/dev/null; echo $?0z wait $(cat Tr)rrsleeprrr&rrr rrr*r ValueError IndexErrorrr) rKrrmrrr new_outputcheck check_output exit_resultexit_strs &&&&& r4r ProcessRegistry._env_poller_loopQs... JJqM$ tH:\%BBO#ZZ"5  0:-w4458P8PP4;4I4I7KcKcJcJd4eG1'  $XJ.PQ$ %yy26<<> L$;$;$=b$A$G$G$IS$P"%++%hZ/QR !#.#K +x<BBDH/,/0C0C0Eb0I0O0O0Q,R)&*GN**73%Q<%!'(' 3/,.)/  !%$&!&&w/  s\0G*G*0A F8:AG*A!G*#3G G*8 G  G* G'$G*&G''G***HHc <V^8dQhRS[/#rr)r2r3s"r4r5rQ}s(((r7c VPpVP4'dVPR4pV'd\V\4'dTMVP RRR7pVP ;_uu_4V;PV, un\VP4VP8d VPVP)RVnRRR4KKVP4RVn\!VR 4'd VP"MR VnVP'V4R# +'giEK;;i \dKs\dKi;i \d!p\PRT4Rp?LRp?ii;i \d!p\PRT4Rp?LRp?ii;i) z2Background thread: read output from a PTY process.rrtru)rwNzPTY stdout reader ended: %sz PTY wait timed out or failed: %sT exitstatusr)r(isaliver isinstancer)decoder&rrr EOFErrorrrrrrhasattrrrr)rKrptyrrOrs&& r4r ProcessRegistry._pty_reader_loop}scll ;++-- HHTNE(25#(>(>uELLQXajLDk$]]]#11T91"7#8#89G c6<V^8dQhRS[RS[S[,/#r session_idrP)r)r r )r2r3s"r4r5rQs$SScSh~&>Sr7c VP;_uu_4VPPV4;'gVPPV4uuRRR4# +'giR#;i)z*Get a session by ID (running or finished).N)r&rGrrH)rKrs&&r4rProcessRegistry.gets@ ZZZ==$$Z0RRDNN4F4Fz4RZZZs >A A/ c&<V^8dQhRS[RS[/#rr)re)r2r3s"r4r5rQsstr7c  T^RIHpVPV4pVf RRRRV 2/#VP;_uu_4VP'dV!VPRR4MRpRRR4RVP R VP RVP'dR MR R VPR \\P!4VP, 4RX/pVP'dVPVR&VP'd RVR&RVR&V# +'giL;i)z9Check status and get new output for a background process. strip_ansiNstatus not_founderrorNo process with ID rrrrrunningruptime_secondsoutput_previewrTr!z=Process recovered after restart -- output history unavailablenote)tools.ansi_striprrr&rrrrrr*rrrr!)rKrrrrrs&& r4pollProcessRegistry.polls/((:& ?k76I*4VW W ]]]JQJ_J_J_Z(=(=ef(EFegN '** w '...hi 7;; c$))+0B0B"BC n   >>>")"3"3F;     !%F: \F6N !]s *D D' c2<V^8dQhRS[RS[RS[RS[/#)rroffsetlimitrPr)r*re)r2r3s"r4r5rQs)  3   d r7c  ^RIHpVPV4pVf RRRRV 2/#VP;_uu_4V!VP4pRRR4XP 4p\ V4pV^8XdV^8dWs)Rp M WrW#,p RVPRVP'dRMR R R PV 4R VR \ V 4 R2/# +'giL;i)z;Read the full output log with optional pagination by lines.rNrrrrrrrrrS total_linesshowingz lines) rrrr&rrrrrr_) rKrrrrr full_outputrXrselecteds &&&& r4read_logProcessRegistry.read_logs/((:& ?k76I*4VW W ]]]$W%:%:;K&&(%j  Q;519VW~HFN3H '** '...hi dii) ; #h-/   ]s C C" c,<V^8dQhRS[RS[RS[/#)rrrrPr)r2r3s"r4r5rQs'BBsBSBDBr7c  ^RIHp^RIHp\ \ P !RR44pTpTpRpV'dWv8d Tp RV RV R2pM T;'gTp VPV4p V f R R R R V 2/#\P!4V ,p \P!4V 8dV P'd4R R RV PRV!V PRR4/p V'dWR&V #VP4'd*R RRV!V PRR4RR/p V'dWR&V #\P!^4KR RRV!V PRR4/p V'dWR&V #RV R2V R&V #)a Block until a process exits, timeout, or interrupt. Args: session_id: The process to wait for. timeout: Max seconds to block. Falls back to TERMINAL_TIMEOUT config. Returns: dict with status ("exited", "timeout", "interrupted", "not_found") and output snapshot. r)_interrupt_eventTERMINAL_TIMEOUT180NzRequested wait of z%s was clamped to configured limit of srrrrrrr timeout_note interruptedrz+User sent a new message -- wait interruptedrzWaited zs, process still runningi0r)rrtools.terminal_toolrr*rgetenvrr monotonicrrris_setr) rKrrrrdefault_timeout max_timeoutrequested_timeoutreffective_timeoutrdeadliners &&& r4rProcessRegistry.waits 08bii(:EBC% # !2!@ + $%6$78**5a9  !2 @ @[ ((:& ?k76I*4VW W>>#&77nn)~~~h!2!2j)>)>uv)FG  -9>* &&((mj)>)>uv)FGI  -9>* JJqM i j!6!6uv!>?  %1> " (//@.AAY%ZF> " r7c&<V^8dQhRS[RS[/#rr)r2r3s"r4r5rQ#s'8'8s'8t'8r7c dVPV4pVf RRRRV 2/#VP'dRRRVP/#VP'dVPP RR 7MVP'dw\'dVPP 4M\P!\P!VPP 4\P4MOVP"'d>VP 'd,VP"P%R VP R 2^R 7RVnRVnVP'V4VP)4RR RVP*/# \ dETP 'd0\P!TP \P4Li;i \\ 3dTPP4Li;i \ dpRRR\-T4/uRp?#Rp?ii;i)zKill a background process.Nrrrralready_exitedrT)forcezkill rrkilledri)rrrr( terminaterrrkillsignalSIGTERMrrkillpggetpgidProcessLookupErrorPermissionErrorrrrrrr))rKrrrs&& r4 kill_processProcessRegistry.kill_process#s((:& ?k76I*4VW W >>>*W..   8|||=LL***6+"{113 "**W__-@-@"A6>>RW[[[''% }L(IST'U!GN #G   " "7 +  " " $h gjjA A'!={{{ V^^<=+O<+OO((*+ 8gwA7 7 8sH F1H  GG+H ,A G9H H A)H G%/GH GH +HH HH H/H*$H/*H/c,<V^8dQhRS[RS[RS[/#rrdatarPr)r2r3s"r4r5rQLs"88c888r7c VPV4pVf RRRRV 2/#VP'dRRRR/#\VR4'dgVP'dU\ V\ 4'dVP R 4MTpVPPV4RR R \V4/#VP'dVPP'gRRRR /#VPPPV4VPPP4RR R \V4/# \dpRRR\ T4/uRp?#Rp?ii;i \dpRRR\ T4/uRp?#Rp?ii;i) zASend raw data to a running process's stdin (no newline appended).NrrrrrzProcess has already finishedr(rtok bytes_writtenz?Process stdin not available (non-local backend or stdin closed)) rrrr(rr)encodewriterrrrzflush)rKrr"rpty_datars&&& r4 write_stdinProcessRegistry.write_stdinLs\((:& ?k76I*4VW W >>>.9WX X 7F # #  <3=dC3H3H4;;w/d ""8, $TCC goo&;&;&;gw0qr r 8 OO ! ! ' ' - OO ! ! ' ' )dOSY? ? < '7CF;; < 8gwA7 7 8s>AD<$AE#< E EE E # F.F<FFc,<V^8dQhRS[RS[RS[/#r!r)r2r3s"r4r5rQgs"99s9#9t9r7c 2VPWR,4#)zGSend data + newline to a running process's stdin (like pressing Enter).rS)r*)rKrr"s&&&r4 submit_stdinProcessRegistry.submit_stdings 4K88r7c&<V^8dQhRS[RS[/#rrrP)r)list)r2r3s"r4r5rQksSDr7c VP;_uu_4\VPP44\VPP44,pRRR4V'd$XUu.uFq3P V8XgKVNK pp.pXEF#pRVP RVPR,RVPRVPR\P!R\P!VP44R \\P!4VP, 4R VP'dR MR R VP 'dVP RRMR/pVP'dVP"VR&VP$'dRVR&VP'V4EK& V# +'giELj;iuupi)z1List all running and recently-finished processes.Nrr:NNrrrz%Y-%m-%dT%H:%M:%SrrrrrrrTr!i8)r&r2rGvaluesrHrrrrrrstrftime localtimerr*rrrr!append)rKr all_sessionsrrentrys&& r4 list_sessionsProcessRegistry.list_sessionsksR ZZZ 4 4 67$t~~?T?T?V:WWL '3L|!yyG7KAA|LLAadd199T?quuquudmm,?PQP\P\A]^ #diikALL&@"Aahhh(I AOOO!//$%"8QS Exxx%&[[k"zzz$(j! MM%   /ZZMsA G5G G G c&<V^8dQhRS[RS[/#r1r)r.)r2r3s"r4r5rQsCDr7c >aVP;_uu_4\;QJd7V3RlVPP44F 'gK RM, RM(!V3RlVPP444uuRRR4# +'giR#;i)z.s2/A W$55QXX5/88TFNr&r\rGr5)rKrs&fr4has_active_processes$ProcessRegistry.has_active_processes\ ZZZ3--/333--/ZZZ8B /B  B c&<V^8dQhRS[RS[/#)rrrPr>)r2r3s"r4r5rQs#$r7c >aVP;_uu_4\;QJd7V3RlVPP44F 'gK RM, RM(!V3RlVPP444uuRRR4# +'giR#;i)z>Check if there are active processes for a gateway session key.c3t<"TF-pVPS8H;'dVP'*xK/ R#5irF)rr)rVrrs& r4rY9ProcessRegistry.has_active_for_session..s2/A ,==QXX=/rBTFNrC)rKrs&fr4has_active_for_session&ProcessRegistry.has_active_for_sessionrFrGc&<V^8dQhRS[RS[/#r1)r)r*)r2r3s"r4r5rQs   s r7c VP;_uu_4VPP4Uu.uF0pVeVPV8XgKVP'dK.VNK2 ppRRR4^pXF?pVP VP 4pVPR4R9gK6V^, pKA V#uupi +'giL^;i)zQKill all running processes, optionally filtered by task_id. Returns count killed.Nr)rr)r&rGr5rrrrr)rKrrtargetsrrrs&& r4kill_allProcessRegistry.kill_alls ZZZ==//11aOqyyG';EFXX1  G&&wzz2Fzz(#'CC!  Zs(CB;B;"B;(C;C C c a\P!4pSPP4UUu.uF$wr#WP, \8gK"VNK& pppVFpSPVK \ SP 4\ SP4,pV\8d?SP'd+\SPV3RlR7pSPVR#R#R#uuppi)zGRemove oldest finished sessions if over MAX_PROCESSES. Must hold _lock.c><SPV,P#rF)rHr)sidrKs&r42ProcessRegistry._prune_if_needed..sDNN3DL Q Q Rs5D/D BD#D D D ED<<Ec <V^8dQhRS[/#)rrP)r*)r2r3s"r4r5rQsBBBr7c n\P4'g^#\P!\P RR74p^pTEFpTP R4pT'gKRp\P!T^4RpT'gKE\TR,TP RR4TP R R 4TP R R 4TTP R 4TP R \P!44RTP RR 4TP RR 4TP RR 4TP R^4R7 pTP;_uu_4Y`PTP&RRR4T^, p\ P#RTP$R,T4TP&^8gEKTP(P+RTPRTP&R TP,RTP.RTP0RTP2/4EK ^RIHpT!\.4T# \ d^#i;i \\3dELi;i +'giL;i \ d$p\ P9RTRR7Rp?T#Rp?ii;i)zn On gateway startup, probe PIDs from checkpoint file. Returns the number of processes recovered as detached. rt)rvrFTrrunknownrrrrrr"r#r$r%) rrrrrrrr!r"r#r$r%Nz'Recovered detached process: %s (pid=%d):N<Ncheck_intervalplatformchat_id thread_idrfz#Could not clear checkpoint file: %srh)rkexistsjsonloads read_textrrrrrrr rr&rGrrinforr%rIr8rr"r#r$rjrgr) rKrl recoveredr:raliverrgrs & r4recover_from_checkpoint'ProcessRegistry.recover_from_checkpointsN %%'' jj!:!:G!:!LMG E))E"CE Qu(\*!IIi;!IIi4 % - < %($yytyy{C!%*YY/A2%F$)II.?$D&+ii0CR&H%*YY/A1%E ZZZ07MM'**- Q  EwWZG[]`a++a/))00$gjj('*B*B%w':':"G$<$<!7#:#:#W%>%> 2GZ R / or 2o  '8  $ Z( R LL>DL Q Q RsG*I .I%I34J III0/I03 J  J4J//J4)rHr&rGrI)z'bash: cannot set terminal process groupz"bash: no job control in this shellzno job control in this shellz!cannot set terminal process groupz)tcsetattr: Inappropriate ioctl for device)NrrNF)Nrr )rUr4rF)r) r9r:r;r<r=r]rL staticmethodr`rrrrrrrrrrrr*r.r;rDrLrQrrcrr}r@rArBs@r4rDrDYs9  nn`EER((6**X((<!!SS 4  8BBH'8'8R88699:  "*"$R6BBr7rD)registryrsr descriptionaFManage background processes started with terminal(background=true). Actions: 'list' (show all), 'poll' (check status + new output), 'log' (full output with pagination), 'wait' (block until done or timeout), 'kill' (terminate), 'write' (send raw stdin data without newline), 'submit' (send data + Enter, for answering prompts). parameterstypeobject propertiesactionstringenumz)Action to perform on background processesrz]Process session ID (from terminal background output). Required for all actions except 'list'.r"z@Text to send to process stdin (for 'write' and 'submit' actions)rintegerzJMax seconds to block for 'wait' action. Returns partial output on timeout.minimumrz6Line offset for 'log' action (default: last 200 lines)rz$Max lines to return for 'log' actionrequiredc z^RIpVPR4pVPRR4pVPR4e\VPRR44MRpVR8Xd*VPR\P VR7/R R 7#VR9EdV'gVPRRV 2/R R 7#VR 8Xd'VP\P V4R R 7#VR 8XdIVP\PWPPR^4VPR^4R7R R 7#VR 8Xd7VP\PWPPR4R7R R 7#VR8Xd'VP\PV4R R 7#VR8XdAVP\PV\VPRR444R R 7#VR8XdAVP\PV\VPRR444R R 7#VPRRV R2/R R 7#)rUNrrrrr2 processes)rF) ensure_asciirlogrrr'submitrzsession_id is required for rr)rrrrr"zUnknown process action: z1. Use: list, poll, log, wait, kill, write, submit)rrrrr'r) rwrr)dumpsprocess_registryr;rrrrr*r.)rqkw_jsonrrrs&, r4_handle_processrWs#ffYG XXh #F48HH\4J4VTXXlB/0\^J {{K)9)G)GPW)G)XYhm{nn E E;;+Fvh)OP_d;e e V ;;/44Z@u;U U u_;;/8888Ha#8RU@V 9 Xfkm m v ;;/44ZR[I\4]lq;r r v ;;/<rZr[r rDrtools.registryrPROCESS_SCHEMArregisterr8r7r4rs>    oo9, J(,,-   8 $"#&66  00 04E E R#$ $ I ?  RJ ~ a  k1  W  E1/ : XJ? *ZL8       r7