You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by cr...@apache.org on 2017/06/20 16:05:48 UTC
incubator-airflow git commit: [AIRFLOW-1286] Use universal newline
when opening log files
Repository: incubator-airflow
Updated Branches:
refs/heads/master fb21bcbcc -> d8891d906
[AIRFLOW-1286] Use universal newline when opening log files
Closes #2363 from ronfung/Airflow-1286
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/d8891d90
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/d8891d90
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/d8891d90
Branch: refs/heads/master
Commit: d8891d906c858ebb1413685a797913918207279a
Parents: fb21bcb
Author: Ron Fung <ro...@wepay.com>
Authored: Tue Jun 20 09:04:37 2017 -0700
Committer: Chris Riccomini <cr...@apache.org>
Committed: Tue Jun 20 09:04:50 2017 -0700
----------------------------------------------------------------------
airflow/task_runner/base_task_runner.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/d8891d90/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 51c3825..1ac822d 100644
--- a/airflow/task_runner/base_task_runner.py
+++ b/airflow/task_runner/base_task_runner.py
@@ -113,7 +113,8 @@ class BaseTaskRunner(LoggingMixin):
proc = subprocess.Popen(
full_cmd,
stdout=subprocess.PIPE,
- stderr=subprocess.STDOUT
+ stderr=subprocess.STDOUT,
+ universal_newlines=True
)
# Start daemon thread to read subprocess logging output