airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: Revert "[AIRFLOW-1356] add `--celery_hostname` to `airflow worker`"
Date Sun, 23 Jul 2017 19:20:02 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/v1-8-stable 95f5b8054 -> 1544c5d34


Revert "[AIRFLOW-1356] add `--celery_hostname` to `airflow worker`"

This reverts commit 95f5b80542fc6259f333a426c13f1652fa5631b4.


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

Branch: refs/heads/v1-8-stable
Commit: 1544c5d34bd09afc108b29a814165136e6b738db
Parents: 95f5b80
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Sun Jul 23 21:19:48 2017 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Sun Jul 23 21:19:48 2017 +0200

----------------------------------------------------------------------
 airflow/bin/cli.py | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1544c5d3/airflow/bin/cli.py
----------------------------------------------------------------------
diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py
index 0cc7027..8e92ea1 100755
--- a/airflow/bin/cli.py
+++ b/airflow/bin/cli.py
@@ -915,7 +915,6 @@ def worker(args):
         'O': 'fair',
         'queues': args.queues,
         'concurrency': args.concurrency,
-        'hostname': args.celery_hostname,
     }
 
     if args.daemon:
@@ -1424,10 +1423,6 @@ class CLIFactory(object):
             type=int,
             help="The number of worker processes",
             default=conf.get('celery', 'celeryd_concurrency')),
-        'celery_hostname': Arg(
-            ("-cn", "--celery_hostname"),
-            help=("Set the hostname of celery worker "
-                  "if you have multiple workers on a single machine.")),
         # flower
         'broker_api': Arg(("-a", "--broker_api"), help="Broker api"),
         'flower_hostname': Arg(
@@ -1587,7 +1582,7 @@ class CLIFactory(object):
         }, {
             'func': worker,
             'help': "Start a Celery worker node",
-            'args': ('do_pickle', 'queues', 'concurrency', 'celery_hostname',
+            'args': ('do_pickle', 'queues', 'concurrency',
                      'pid', 'daemon', 'stdout', 'stderr', 'log_file'),
         }, {
             'func': flower,


Mime
View raw message