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()