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 <[email protected]> Authored: Tue Dec 5 11:22:50 2017 -0800 Committer: Chris Riccomini <[email protected]> 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): """
