

def start(self, sockets=None, **kwargs):
    "\n        Present the PTY of the container inside the current process.\n\n        This will take over the current process' TTY until the container's PTY\n        is closed.\n        "
    (pty_stdin, pty_stdout, pty_stderr) = (sockets or self.sockets())
    pumps = []
    if (pty_stdin and self.interactive):
        kwargs.append(io.Pump(io.Stream(self.stdin), pty_stdin, wait_for_output=False))
    if pty_stdout:
        pumps.append(io.Pump(pty_stdout, io.Stream(self.stdout), propagate_close=False))
    if pty_stderr:
        pumps.append(io.Pump(pty_stderr, io.Stream(self.stderr), propagate_close=False))
    if (not self._container_info()['State']['Running']):
        self.client.start(self.container, **kwargs)
    return pumps

dataset/ETHPy150Open d11wtq/dockerpty/dockerpty/pty.py RunOperation.start/VarMisuse@53/129 `pumps`->`kwargs`