[Celery] fix the celery worker concurrency settings (#3126)

This commit is contained in:
丁桂涛 2017-07-15 00:44:41 +08:00 committed by Maxime Beauchemin
parent a626f994bf
commit 256a521bf1
1 changed files with 1 additions and 1 deletions

View File

@ -192,7 +192,7 @@ def worker(workers):
celery_app.conf.update(CELERYD_CONCURRENCY=workers)
elif config.get("SUPERSET_CELERY_WORKERS"):
celery_app.conf.update(
worker_concurrency=config.get("SUPERSET_CELERY_WORKERS"))
CELERYD_CONCURRENCY=config.get("SUPERSET_CELERY_WORKERS"))
worker = celery_worker.worker(app=celery_app)
worker.run()