(self, msg, stdin, stdout, stderr)
| 1738 | return transport, protocol |
| 1739 | |
| 1740 | def _log_subprocess(self, msg, stdin, stdout, stderr): |
| 1741 | info = [msg] |
| 1742 | if stdin is not None: |
| 1743 | info.append(f'stdin={_format_pipe(stdin)}') |
| 1744 | if stdout is not None and stderr == subprocess.STDOUT: |
| 1745 | info.append(f'stdout=stderr={_format_pipe(stdout)}') |
| 1746 | else: |
| 1747 | if stdout is not None: |
| 1748 | info.append(f'stdout={_format_pipe(stdout)}') |
| 1749 | if stderr is not None: |
| 1750 | info.append(f'stderr={_format_pipe(stderr)}') |
| 1751 | logger.debug(' '.join(info)) |
| 1752 | |
| 1753 | async def subprocess_shell(self, protocol_factory, cmd, *, |
| 1754 | stdin=subprocess.PIPE, |
no test coverage detected