yIf%dZddlmZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZmZmZddlmZdd lmZmZdd lmZe rdd lmZdd lmZdd lmZee gdfZ!eee!e!ge"fZ#ej$e%Z&GddZ'GddeZ(GddeZ)GddeZ*GddZ+dZ,dS)zAAbstract base API for executing commands within tox environments.) annotationsN)ABCabstractmethod)contextmanager) TYPE_CHECKINGAnyCallableIteratorNoReturnSequencecast)Fore)ExecuteRequest StdinSource) SyncWrite) TracebackType)OutErr)ToxEnvcveZdZd dZed dZed dZed d Zed d Z d S)ExecuteOptionsenvrreturnNonec||_dSN)_env)selfrs C/var/www/piapp/venv/lib/python3.11/site-packages/tox/execute/api.py__init__zExecuteOptions.__init__s  c|jdgdtd|jdgdtd|jdgd td dS) Nsuicide_timeoutz6timeout to allow process to exit before sending SIGINTg)keysdescof_typedefaultinterrupt_timeoutz+timeout before sending SIGTERM after SIGINTg333333?terminate_timeoutz,timeout before sending SIGKILL after SIGTERMg?)conf add_configfloatclsrs r register_confzExecuteOptions.register_conf s #$I    %&>    %&?      r!r,cLtt|jjdS)Nr#r r,rr*rs rr#zExecuteOptions.suicide_timeout5sE49>*;<===r!cLtt|jjdS)Nr(r1r2s rr(z ExecuteOptions.interrupt_timeout9E49>*=>???r!cLtt|jjdS)Nr)r1r2s rr)z ExecuteOptions.terminate_timeout=r4r!Nrrrrrr,) __name__ __module__ __qualname__r classmethodr/propertyr#r(r)r!rrrs   [ (>>>X>@@@X@@@@X@@@r!rceZdZddZeedd ZedddZeddZeddZ d dZ ed!dZ ed!dZ ed"dZ d S)# ExecuteStatusoptionsroutrerrrrc>d|_||_||_||_dSr)outcomer@_out_err)rr@rArBs rr zExecuteStatus.__init__Cs"'+    r! int | NonectrNotImplementedErrorr2s r exit_codezExecuteStatus.exit_codeI "!r!Ntimeout float | NonectrrI)rrMs rwaitzExecuteStatus.waitN!!r!contentstrctrrI)rrRs r write_stdinzExecuteStatus.write_stdinRrQr!ctrrIr2s r interruptzExecuteStatus.interruptVrQr!tuple[SyncWrite, SyncWrite]c@|j|jf}||c|_|_|Sr)rErF)rrArBress r set_out_errzExecuteStatus.set_out_errZs%i""C 49 r! bytearrayc|jjSr)rErRr2s rrAzExecuteStatus.out_ y  r!c|jjSr)rFrRr2s rrBzExecuteStatus.errcr^r!dict[str, Any]ciSrr=r2s rmetadatazExecuteStatus.metadatags r!)r@rrArrBrrr)rrGr)rMrNrrG)rRrSrrrr)rArrBrrrX)rr\)rr`)r8r9r:r r<rrKrPrUrWr[rArBrbr=r!rr?r?Bs+ """^X"""""^""""^""""^" !!!X!!!!X!Xr!r?creZdZUdZeZded<ddZeddZ e ddZ e ddZ dS)Executez0Abstract API for execution of a tox environment.ztype[ExecuteOptions] _option_classcoloredboolrrc||_dSr)_colored)rrgs rr zExecute.__init__qs  r!requestrshowout_errrrrIterator[ExecuteStatus]c #Ktj} |dj|dj}}t|j|r|nd}t|j|r|nd|jr t jnd} |5| 5||| ||| } | 5} | Vdddn #1swxYwY| j } dddn #1swxYwYdddn #1swxYwYtj} n#tj} wxYwt||| |j | j || | j | j | _dS)Nrr)time monotonicbufferrnamerjrREDbuild_instancerfrKOutcometextcmdrbrD)rrkrlrmrstartrArBout_syncerr_syncinstancestatusrKends rcallz Execute.callts   #qz('!**;C $+@33DAAH $+@33DdmBe$((aeffH - -8 - -..w8J8J38O8OQY[cdd! LLL!!!!!!!!!!!!!!!",  - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - .""CC$.""C " " " "    M M   L O   sxA"D9C0<.C*B;/ C;B? ?CB?  C C0C C0 C !C0$ D0C44D7C48DD$r@rrArrBExecuteInstancectrrIrrkr@rArBs rruzExecute.build_instances "!r!c:|j|dSr)rfr/r-s rr/zExecute.register_confs '',,,,,r!N)rgrhrr) rkrrlrhrmrrrrrn) rkrr@rrArrBrrrr6)r8r9r:__doc__rrf__annotations__r rrrrur;r/r=r!rrerels::*8M8888       ^ @"""^"---[---r!receZdZdZdd Zedd ZeddZeddZ eddZ eeddZ dS) rz#An instance of a command execution.rkrr@rrArrBrrc>||_||_||_||_dSr)rkr@rErFrs rr zExecuteInstance.__init__s"    r!ContentHandlerc|jjSr)rEhandlerr2s r out_handlerzExecuteInstance.out_handlerr^r!c|jjSr)rFrr2s r err_handlerzExecuteInstance.err_handlerr^r!r?ctrrIr2s r __enter__zExecuteInstance.__enter__rQr!exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NonectrrI)rrrrs r__exit__zExecuteInstance.__exit__s "!r! Sequence[str]ctrrIr2s rrxzExecuteInstance.cmdrLr!N) rkrr@rrArrBrrr)rr)rr?)rrrrrrrr)rr) r8r9r:rr r<rrrrrrxr=r!rrrs-- !!!X!!!!X!"""^""""^""""^X"""r!rcneZdZdZdZd#dZd$dZd%dZd&dZd&dZ d'dZ d(dZ e d)dZ d*d!Zd"S)+rvzResult of a command execution.rrkrshow_on_standardrhrKrGrArSrBryr,r~rxrrbr`rrc ||_||_||_||_||_||_||_||_| |_dS)aa Create a new execution outcome. :param request: the execution request :param show_on_standard: a flag indicating if the execution was shown on stdout/stderr :param exit_code: the exit code for the execution :param out: the standard output of the execution :param err: the standard error of the execution :param start: a timer sample for the start of the execution :param end: a timer sample for the end of the execution :param cmd: the command as executed :param metadata: additional metadata attached to the execution N) rkrrKrArBryr~rxrb) rrkrrKrArBryr~rxrbs rr zOutcome.__init__sH2 0"   r!c"|j|jkSr)rKOKr2s r__bool__zOutcome.__bool__s~((r!cZ|jjd|jd|jdd|jjS)Nz: exit z in z.2fz seconds for ) __class__r8rKelapsedrk shell_cmdr2s r__repr__zOutcome.__repr__sJ~& - -t~ - -4< ] - -L* - - r!c|j$|j|jkr||tjdS)z$Assert that the execution succeeded.NrKr _assert_fail log_run_doneloggingINFOr2s rassert_successzOutcome.assert_successF > %$.DG*C*C       ','''''r!c|j$|j|jkr||tjdS)z!Assert that the execution failed.Nrr2s rassert_failurezOutcome.assert_failurerr!r c|jdur|jr]tj|j|jdstjd|jrtjtj tj|jtjtj |jdstjd| tj t|j)NF )rrAsysstdoutwriteendswithrBstderrrrtRESETrrCRITICAL SystemExitrKr2s rrzOutcome._assert_fails  E ) )x +   ***x((..+J$$T***x +   ***   ***   ,,,x((..+J$$T*** '*+++(((r!lvlintc |j}d}|jr9ddd|jD}t|d|j|j|j|j |dS)z Log that the run was done. :param lvl: the level on what to log as interpreted by :func:`logging.log`  z, c3*K|]\}}|d|VdS)=Nr=).0kvs r z'Outcome.log_run_done..s0$R$RDAqZZAZZ$R$R$R$R$R$Rr!zexit %s (%.2f seconds) %s> %s%sN) rkrbjoinitemsLOGGERlogrKrcwdr)rrreqrbs rrzOutcome.log_run_dones l = UT499$R$RDMrs8GG"""""" ########%%%%%%SSSSSSSSSSSSSSSSSS00000000'######!!!!!!&&&&&&5'4-( ^^^DcI J  8 $ $#@#@#@#@#@#@#@#@L'''''C'''T5-5-5-5-5-c5-5-5-p!"!"!"!"!"c!"!"!"Hg"g"g"g"g"g"g"g"T r!