From e22bcab608ed405a1259b62b311fc3bc00edf229 Mon Sep 17 00:00:00 2001 From: Matt Davis Date: Mon, 11 Jul 2022 01:40:54 -0400 Subject: [PATCH] Remove dead code and add missing pyparsing file from last vevndoring. --- pipenv/process.py | 82 -------------------------------- pipenv/vendor/pyparsing/py.typed | 0 2 files changed, 82 deletions(-) delete mode 100644 pipenv/process.py create mode 100644 pipenv/vendor/pyparsing/py.typed diff --git a/pipenv/process.py b/pipenv/process.py deleted file mode 100644 index 58766459..00000000 --- a/pipenv/process.py +++ /dev/null @@ -1,82 +0,0 @@ -import os -import subprocess -import threading -from time import monotonic as _time - -from pipenv._compat import DEFAULT_ENCODING -from pipenv.cmdparse import Script - - -class PopenProcess: - """A wrapper of subprocess.Popen that - doesn't need to worry about the Pipe buffer exceeding the limit. - """ - - def __init__( - self, - args, - *, - block=True, - encoding=DEFAULT_ENCODING, - env=None, - timeout=None, - **other_kwargs - ): - self.blocking = block - self.env = env - self.script = Script.parse(args) - if env is not None: - env = dict(os.environ, **env) - other_kwargs["env"] = env - other_kwargs["stdout"] = subprocess.PIPE - other_kwargs["stderr"] = subprocess.PIPE - self._process = subprocess.Popen( - args, universal_newlines=True, encoding=encoding, **other_kwargs - ) - self._endtime = None - if timeout is not None: - self._endtime = _time() + timeout - self.out_buffer = [] - self.err_buffer = [] - self._start_polling() - - def wait(self): - try: - self._process.wait(self._remaining_time()) - except subprocess.TimeoutExpired: - self._process.kill() - raise - finally: - self.out_reader.join() - self.err_reader.join() - - @property - def return_code(self): - return self._process.returncode - - @property - def out(self): - return "".join(self.out_buffer) - - @property - def err(self): - return "".join(self.err_buffer) - - def _remaining_time(self): - if self._endtime is None: - return None - return self._endtime - _time() - - def _pipe_output(self): - for line in iter(self._process.stdout.readline, ""): - self.out_buffer.append(line) - - def _pipe_err(self): - for line in iter(self._process.stderr.readline, ""): - self.err_buffer.append(line) - - def _start_polling(self): - self.out_reader = threading.Thread(target=self._pipe_output) - self.err_reader = threading.Thread(target=self._pipe_err) - self.out_reader.start() - self.err_reader.start() diff --git a/pipenv/vendor/pyparsing/py.typed b/pipenv/vendor/pyparsing/py.typed new file mode 100644 index 00000000..e69de29b