LOGGER = logging.getLogger(__name__)
DEFAULT_CHUNKSIZE = 128000
-DEFAULT_TIMEOUT = 120
+DEFAULT_TIMEOUT = 600
# pylint: disable=invalid-name
return await self._proc.stdout.readexactly(n)
except asyncio.IncompleteReadError as err:
return err.partial
- except asyncio.TimeoutError:
- return b""
async def read(self, n: int, timeout: int = DEFAULT_TIMEOUT) -> bytes:
"""
"""
if self.closed:
return b""
- try:
- async with _timeout(timeout):
- return await self._proc.stdout.read(n)
- except asyncio.TimeoutError:
- return b""
+ async with _timeout(timeout):
+ return await self._proc.stdout.read(n)
async def write(self, data: bytes) -> None:
"""Write data to process stdin."""