[AIRFLOW-6099] Add host name to task runner log (apache#6688)

wendy-wong · Nov 29, 2019 · f2f8d01 · f2f8d01
1 parent 15e30dd
commit f2f8d01
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/airflow/task/task_runner/base_task_runner.py b/airflow/task/task_runner/base_task_runner.py
@@ -25,6 +25,7 @@
 from airflow.configuration import conf
 from airflow.utils.configuration import tmp_configuration_copy
 from airflow.utils.log.logging_mixin import LoggingMixin
+from airflow.utils.net import get_hostname
 
 PYTHONPATH_VAR = 'PYTHONPATH'
 
@@ -121,6 +122,7 @@ def run_command(self, run_with=None):
         run_with = run_with or []
         full_cmd = run_with + self._command
 
+        self.log.info("Running on host: %s", get_hostname())
         self.log.info('Running: %s', full_cmd)
         proc = subprocess.Popen(
             full_cmd,