Repository: incubator-airflow Updated Branches: refs/heads/master 3ceb3abf1 -> eea5ff8b6
[AIRFLOW-853] use utf8 encoding for stdout line decode Closes #2060 from ming-wu/master Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/eea5ff8b Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/eea5ff8b Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/eea5ff8b Branch: refs/heads/master Commit: eea5ff8b688c8d7e2aa65c013d36be506a6a532f Parents: 3ceb3ab Author: Ming Wu <[email protected]> Authored: Fri Feb 10 19:47:47 2017 -0500 Committer: Jeremiah Lowin <[email protected]> Committed: Fri Feb 10 19:47:47 2017 -0500 ---------------------------------------------------------------------- airflow/contrib/operators/ssh_execute_operator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/eea5ff8b/airflow/contrib/operators/ssh_execute_operator.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/operators/ssh_execute_operator.py b/airflow/contrib/operators/ssh_execute_operator.py index dd4c3b4..dd9e197 100644 --- a/airflow/contrib/operators/ssh_execute_operator.py +++ b/airflow/contrib/operators/ssh_execute_operator.py @@ -142,7 +142,7 @@ class SSHExecuteOperator(BaseOperator): logging.info("Output:") line = '' for line in iter(sp.stdout.readline, b''): - line = line.decode().strip() + line = line.decode('utf_8').strip() logging.info(line) sp.wait() logging.info("Command exited with "
