Repository: incubator-airflow Updated Branches: refs/heads/master a1f4227be -> 460134bf2
[AIRFLOW-908] Print hostname at the start of cli run Closes #2329 from AllisonWang/master Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/460134bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/460134bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/460134bf Branch: refs/heads/master Commit: 460134bf25ccce28a7c0588a1ad0505328c71e4f Parents: a1f4227 Author: Allison Wang <allisonwang...@gmail.com> Authored: Tue May 30 11:26:24 2017 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Tue May 30 11:26:27 2017 -0700 ---------------------------------------------------------------------- airflow/bin/cli.py | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/460134bf/airflow/bin/cli.py ---------------------------------------------------------------------- diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py index 6aa7119..41f979f 100755 --- a/airflow/bin/cli.py +++ b/airflow/bin/cli.py @@ -19,6 +19,7 @@ import logging import reprlib import os +import socket import subprocess import textwrap import warnings @@ -384,6 +385,9 @@ def run(args, dag=None): level=settings.LOGGING_LEVEL, format=settings.LOG_FORMAT) + hostname = socket.getfqdn() + logging.info("Running on host {}".format(hostname)) + if not args.pickle and not dag: dag = get_dag(args) elif not dag:
