Change decoding to utf8 to account for utf terminal encoding. Resolves #54. Added call on partial host failure tests to catch partial host list failure errors - #52. Merged changes from #53. Resolves #52 - resolves #53.

Author: Dan

pssh/ssh_client.py

@@ -237,7 +237,7 @@ def exec_command(self, command, sudo=False, user=None, **kwargs):
     def _read_output_buffer(self, output_buffer, prefix=''):
         """Read from output buffers and log to host_logger"""
         for line in output_buffer:
-            output = line.strip().decode('ascii')
+            output = line.strip().decode('utf8')
             host_logger.info("[%s]%s\t%s", self.host, prefix, output,)
             yield output
 

tests/test_pssh_client.py

@@ -200,6 +200,7 @@ def test_pssh_client_hosts_list_part_failure(self):
                                    agent=self.agent)
         output = client.run_command(self.fake_cmd,
                                     stop_on_errors=False)
+        client.join(output)
         self.assertTrue(hosts[0] in output,
                         msg="Successful host does not exist in output - output is %s" % (output,))
         self.assertTrue(hosts[1] in output,