You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/03/13 04:45:21 UTC
[23/45] incubator-airflow git commit: [AIRFLOW-853] use utf8 encoding
for stdout line decode
[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-stable
Commit: 101700853896fdb90cda4267b5310e6c8811f4f0
Parents: 3918e5e
Author: Ming Wu <mi...@ubisoft.com>
Authored: Fri Feb 10 19:47:47 2017 -0500
Committer: Bolke de Bruin <bo...@Bolkes-MacBook-Pro.local>
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 "