[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/10170085 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/10170085 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/10170085 Branch: refs/heads/v1-8-test Commit: 101700853896fdb90cda4267b5310e6c8811f4f0 Parents: 3918e5e Author: Ming Wu <[email protected]> Authored: Fri Feb 10 19:47:47 2017 -0500 Committer: Bolke de Bruin <[email protected]> Committed: Sun Mar 12 08:10:12 2017 -0700 ---------------------------------------------------------------------- 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/10170085/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 "
