From 256a521bf1083222f16ecbc02ac3d01522ebc9e3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=81=E6=A1=82=E6=B6=9B?= Date: Sat, 15 Jul 2017 00:44:41 +0800 Subject: [PATCH] [Celery] fix the celery worker concurrency settings (#3126) --- superset/cli.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/superset/cli.py b/superset/cli.py index 46b0ca794b..f6163bb140 100755 --- a/superset/cli.py +++ b/superset/cli.py @@ -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()