o :ήc@sddlmZddlmZddlmZmZmZmZddl m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZdd lmZd eed d d d d deeeeeeeffdeedeee e d fdeee e d fdedeeedd fdeeeefdeddfddZeeed d d ddeeeeeeeffdeee e d fdeee e d fdeee e d fdeeedd fdeeeefdedefddZd S))BytesIO)PathLike)DEVNULLPIPECalledProcessErrorCompletedProcess) IOAny AsyncIterableListMappingOptionalSequenceUnioncast)Process) get_asynclib)create_task_groupNTF)inputstdoutstderrcheckcwdenvstart_new_sessioncommandrrrrrz PathLike[str]rrreturnzCompletedProcess[bytes]c sdttdtddffdd }t||rtnt|||||dIdH4IdHn} ddgzRt4IdH>} | jr?| || jd| j rJ| || j d | j r`|r`| j |IdH| j IdH| IdHWdIdHn 1IdHswwYWn ty| wWdIdHn 1IdHswY\} } |r| jdkrttt| 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 streamindexrNcs6t}|2z 3dHW}||q6||<dS)N)rwritegetvalue)rr bufferchunkstream_contents@/tmp/pip-target-vg8gfxp4/lib/python/anyio/_core/_subprocesses.py drain_stream8s  z!run_process..drain_streamstdinrrrrrrr)r bytesint open_processrrrr start_soonrr+sendaclosewait BaseExceptionkill returncoderrr) rrrrrrrrr)processtgoutputerrorsr'r%r( run_processsF#  ( (r:r*r+c 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 )shellr+rrrrrN) isinstancestrrr.)rr+rrrrrr;r'r'r(r._s  r.)iorosr subprocessrrrrtypingrr r r r r rrrabcr _eventloopr_tasksrr=r,r-boolr:r.r'r'r'r(sp ,    M