(self, cmd: List[str])
| 25 | |
| 26 | class UnixExecutor: |
| 27 | async def execute(self, cmd: List[str]) -> Tuple[int, str, str]: |
| 28 | process = await asyncio.create_subprocess_exec( |
| 29 | *cmd, |
| 30 | stdout=asyncio.subprocess.PIPE, |
| 31 | stderr=asyncio.subprocess.PIPE |
| 32 | ) |
| 33 | stdout, stderr = await process.communicate() |
| 34 | return process.returncode, stdout.decode(), stderr.decode() |
| 35 | |
| 36 | |
| 37 | class DockerExecutorBase(ABC): |