airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From criccom...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1876] Write subtask id to task log header
Date Tue, 05 Dec 2017 19:23:01 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master ff0d75f06 -> a9ceca5e0


[AIRFLOW-1876] Write subtask id to task log header

Closes #2835 from wrp/subtask-id


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

Branch: refs/heads/master
Commit: a9ceca5e04d3bdfbd34adc4ef5bf95c5cbf5c954
Parents: ff0d75f
Author: William Pursell <williamp@wepay.com>
Authored: Tue Dec 5 11:22:50 2017 -0800
Committer: Chris Riccomini <criccomini@apache.org>
Committed: Tue Dec 5 11:22:50 2017 -0800

----------------------------------------------------------------------
 airflow/task_runner/base_task_runner.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/a9ceca5e/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 7670cbe..849c0c7 100644
--- a/airflow/task_runner/base_task_runner.py
+++ b/airflow/task_runner/base_task_runner.py
@@ -97,7 +97,9 @@ class BaseTaskRunner(LoggingMixin):
                 line = line.decode('utf-8')
             if len(line) == 0:
                 break
-            self.log.info(u'Subtask: %s', line.rstrip('\n'))
+            self.log.info(u'Job {}: Subtask {} %s'.format(
+                self._task_instance.job_id, self._task_instance.task_id),
+                line.rstrip('\n'))
 
     def run_command(self, run_with, join_args=False):
         """


Mime
View raw message