Signed-off-by: Oleh Prypin <oleh@pryp.in>
self.gateway = self._make_gateway(hostname)
def _make_gateway(self, hostname):
- return execnet.makegateway(
+ gateway = execnet.makegateway(
self._make_connection_string(hostname)
)
+ gateway.reconfigure(py2str_as_py3str=False, py3str_as_py2str=False)
+ return gateway
def _detect_sudo(self, _execnet=None):
"""
try:
received = result.receive(timeout)
level_received, message = list(received.items())[0]
+ if not isinstance(message, str):
+ message = message.decode('utf-8')
log_map[level_received](message.strip('\n'))
except EOFError:
break