o #6dq@sddlmZddlmZddlmZddlmZmZm Z m Z ddl m Z m Z mZmZmZmZddlmZdd lmZdd lmZd eed d d d dd&dd Zeeed d d d!d'd$d%Zd S)() annotations)BytesIO)PathLike)DEVNULLPIPECalledProcessErrorCompletedProcess)IOAny AsyncIterableMappingSequencecast)Process) get_asynclib)create_task_groupNTF)inputstdoutstderrcheckcwdenvstart_new_sessioncommand#str | bytes | Sequence[str | bytes]r bytes | Nonerint | IO[Any] | Nonerrboolr"str | bytes | PathLike[str] | NonerMapping[str, str] | NonerreturnCompletedProcess[bytes]c spd fdd }t||rtnt|||||d Id H4Id Hn} d d gzRt4Id H>} | jr7| || jd | jrB| || jd | jrX|rX| j|Id H| j Id H| Id HWd Id Hn 1Id HsowYWn t y| wWd Id Hn 1Id HswY\} } |r| j d krttt| j || | t|tt| j | | S)a Run an external command in a subprocess and wait until it completes. .. seealso:: :func:`subprocess.run` :param command: either a string to pass to the shell, or an iterable of strings containing the executable name or path and its arguments :param input: bytes passed to the standard input of the subprocess :param stdout: either :data:`subprocess.PIPE` or :data:`subprocess.DEVNULL` :param stderr: one of :data:`subprocess.PIPE`, :data:`subprocess.DEVNULL` or :data:`subprocess.STDOUT` :param check: if ``True``, raise :exc:`~subprocess.CalledProcessError` if the process terminates with a return code other than 0 :param cwd: If not ``None``, change the working directory to this before running the command :param env: if not ``None``, this mapping replaces the inherited environment variables from the parent process :param start_new_session: if ``true`` the setsid() system call will be made in the child process prior to the execution of the subprocess. (POSIX only) :return: an object representing the completed process :raises ~subprocess.CalledProcessError: if ``check`` is ``True`` and the process exits with a nonzero return code streamAsyncIterable[bytes]indexintr"Nonecs6t}|2z 3dHW}||q6||<dS)N)rwritegetvalue)r$r&bufferchunkZstream_contentspC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\anyio/_core/_subprocesses.py drain_stream7s  z!run_process..drain_streamstdinrrrrrNrr)r$r%r&r'r"r() open_processrrrrZ start_soonrr2sendaclosewait BaseExceptionkill returncoderrr'r) rrrrrrrrr0processtgoutputerrorsr.r-r/ run_processsF#  ( (r>r1r2rc s.t|t}tj||||||||dIdHS)a Start an external command in a subprocess. .. seealso:: :class:`subprocess.Popen` :param command: either a string to pass to the shell, or an iterable of strings containing the executable name or path and its arguments :param stdin: one of :data:`subprocess.PIPE`, :data:`subprocess.DEVNULL`, a file-like object, or ``None`` :param stdout: one of :data:`subprocess.PIPE`, :data:`subprocess.DEVNULL`, a file-like object, or ``None`` :param stderr: one of :data:`subprocess.PIPE`, :data:`subprocess.DEVNULL`, :data:`subprocess.STDOUT`, a file-like object, or ``None`` :param cwd: If not ``None``, the working directory is changed before executing :param env: If env is not ``None``, it must be a mapping that defines the environment variables for the new process :param start_new_session: if ``true`` the setsid() system call will be made in the child process prior to the execution of the subprocess. (POSIX only) :return: an asynchronous process object )shellr2rrrrrN) isinstancestrrr3)rr2rrrrrr?r.r.r/r3^s  r3)rrrrrrrrrrrr rr!rrr"r#)rrr2rrrrrrr rr!rrr"r) __future__riorosr subprocessrrrrtypingr r r r r rabcrZ _eventloopr_tasksrr>r3r.r.r.r/s.     M