airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/4] incubator-airflow git commit: [AIRFLOW-783] Fix py3 incompatibility in BaseTaskRunner
Date Thu, 26 Jan 2017 18:44:11 GMT
[AIRFLOW-783] Fix py3 incompatibility in BaseTaskRunner


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/5184c6e2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/5184c6e2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/5184c6e2

Branch: refs/heads/v1-8-test
Commit: 5184c6e2f108d3db15205ad806e6529b5e0b4259
Parents: 15f1abe
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Thu Jan 26 14:34:08 2017 +0100
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Thu Jan 26 15:52:32 2017 +0100

----------------------------------------------------------------------
 airflow/task_runner/base_task_runner.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/5184c6e2/airflow/task_runner/base_task_runner.py
----------------------------------------------------------------------
diff --git a/airflow/task_runner/base_task_runner.py b/airflow/task_runner/base_task_runner.py
index 69802a8..51c3825 100644
--- a/airflow/task_runner/base_task_runner.py
+++ b/airflow/task_runner/base_task_runner.py
@@ -89,7 +89,7 @@ class BaseTaskRunner(LoggingMixin):
 
     def _read_task_logs(self, stream):
         while True:
-            line = stream.readline()
+            line = stream.readline().decode('utf-8')
             if len(line) == 0:
                 break
             self.logger.info('Subtask: {}'.format(line.rstrip('\n')))


Mime
View raw message