airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1780] Fix long output lines with unicode from hanging parent
Date Tue, 07 Nov 2017 00:02:19 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 3fde1043f -> 1a7b63eb1


[AIRFLOW-1780] Fix long output lines with unicode from hanging parent

Fix long task output lines with unicode from
hanging parent process. Tasks that create output
that gets piped into a file in the parent airflow
process would hang if they had long lines with
unicode characters.

Closes #2758 from aoen/ddavydov--
fix_unicode_output_string


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

Branch: refs/heads/master
Commit: 1a7b63eb16ffa1cb97cb09f71997dcd39f28e645
Parents: 3fde104
Author: Dan Davydov <dan.davydov@airbnb.com>
Authored: Mon Nov 6 16:01:59 2017 -0800
Committer: Dan Davydov <dan.davydov@airbnb.com>
Committed: Mon Nov 6 16:02:02 2017 -0800

----------------------------------------------------------------------
 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/1a7b63eb/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 6a07db2..f4b4f2d 100644
--- a/airflow/task_runner/base_task_runner.py
+++ b/airflow/task_runner/base_task_runner.py
@@ -95,7 +95,7 @@ class BaseTaskRunner(LoggingMixin):
                 line = line.decode('utf-8')
             if len(line) == 0:
                 break
-            self.log.info('Subtask: %s', line.rstrip('\n'))
+            self.log.info(u'Subtask: %s', line.rstrip('\n'))
 
     def run_command(self, run_with, join_args=False):
         """


Mime
View raw message