You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/07/23 19:20:02 UTC
incubator-airflow git commit: Revert "[AIRFLOW-1356] add
`--celery_hostname` to `airflow worker`"
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 <bo...@xs4all.nl>
Authored: Sun Jul 23 21:19:48 2017 +0200
Committer: Bolke de Bruin <bo...@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,