U Rhz @snUddlmZddlZddlmZmZmZmZddlm Z ddl m Z ddl m Z mZmZmZddlmZmZmZmZdd lmZd d lmZd d lmZejd krddlmZn ddlmZeee ddfZ!de"d<deeddddddddddddddddddddddd d!d!d"dd#d$d%d&Z#eeeddddddddddd' dddddddddd d!d!d"dd(d)d*d+Z$dS),) annotationsN) AsyncIterableIterableMappingSequence)BytesIO)PathLike)DEVNULLPIPECalledProcessErrorCompletedProcess)IOAnyUnioncast)Process)get_async_backend)create_task_group) ) TypeAliasz PathLike[str]zPathLike[bytes]rStrOrBytesPathTF)inputstdoutstderrcheckcwdenv startupinfo creationflagsstart_new_sessionpass_fdsusergroup extra_groupsumaskz)StrOrBytesPath | Sequence[StrOrBytesPath]z bytes | Nonezint | IO[Any] | NoneboolzStrOrBytesPath | NonezMapping[str, str] | Nonerintz Sequence[int]zstr | int | NonezIterable[str | int] | NonezCompletedProcess[bytes])commandrrrrr r!r"r#r$r%r&r'r(r)returncs6ddddfdd }t||r"tnt||||||| | | | | |dIdH4IdH}ddgt4IdHl}|jr|||jd |jr|||jd |jr|r|j|IdH|j IdH| IdHW5QIdHRXW5QIdHRX\}}|r |j d kr t t t|j |||t|t t|j ||S) aq 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: 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 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 startupinfo: an instance of :class:`subprocess.STARTUPINFO` that can be used to specify process startup parameters (Windows only) :param creationflags: flags that can be used to control the creation of the subprocess (see :class:`subprocess.Popen` for the specifics) :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) :param pass_fds: sequence of file descriptors to keep open between the parent and child processes. (POSIX only) :param user: effective user to run the process as (Python >= 3.9, POSIX only) :param group: effective group to run the process as (Python >= 3.9, POSIX only) :param extra_groups: supplementary groups to set in the subprocess (Python >= 3.9, POSIX only) :param umask: if not negative, this umask is applied in the child process before running the given command (Python >= 3.9, 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 zAsyncIterable[bytes]r+None)streamindexr-cs4t}|2z3dHW}||q 6||<dS)N)rwritegetvalue)r/r0bufferchunkZstream_contentsr?./venv/lib/python3.8/site-packages/anyio/_core/_subprocesses.py drain_streamNsz!run_process..drain_stream stdinrrr r!r"r#r$r%r&r'r(r)Nrr) open_processr r rrZ start_soonrr9sendaclosewait returncoder rr+r )r,rrrrr r!r"r#r$r%r&r'r(r)r7Zprocesstgoutputerrorsrr5r6 run_processs@8  .rBr8r)r,r9rrr r!r"r#r$r%r&r'r(r)r-c  si}| dk r&tjdkrtd| |d<| dk rHtjdkr@td| |d<| dk rjtjdkrbtd| |d<| d krtjdkrtd | |d <tj|f||||||||| d |IdHS) ac 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 creationflags: flags that can be used to control the creation of the subprocess (see :class:`subprocess.Popen` for the specifics) :param startupinfo: an instance of :class:`subprocess.STARTUPINFO` that can be used to specify process startup parameters (Windows only) :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) :param pass_fds: sequence of file descriptors to keep open between the parent and child processes. (POSIX only) :param user: effective user to run the process as (Python >= 3.9; POSIX only) :param group: effective group to run the process as (Python >= 3.9; POSIX only) :param extra_groups: supplementary groups to set in the subprocess (Python >= 3.9; POSIX only) :param umask: if not negative, this umask is applied in the child process before running the given command (Python >= 3.9; POSIX only) :return: an asynchronous process object N)r z0the 'user' argument requires Python 3.9 or laterr&z1the 'group' argument requires Python 3.9 or laterr'z8the 'extra_groups' argument requires Python 3.9 or laterr(rz1the 'umask' argument requires Python 3.9 or laterr)) r9rrr r!r"r#r$r%)sys version_info TypeErrorrr:)r,r9rrr r!r"r#r$r%r&r'r(r)kwargsrrr6r:zs@2     r:)%Z __future__rrDZcollections.abcrrrriorosr subprocessr r r r typingr rrrabcrZ _eventlooprZ_tasksrrErZtyping_extensionsstrbytesr__annotations__rBr:rrrr6sV        0g