diff --git a/superset/cli.py b/superset/cli.py
index e4165e6716b..c5dea446efc 100755
--- a/superset/cli.py
+++ b/superset/cli.py
@@ -195,7 +195,7 @@ def worker(workers):
             CELERYD_CONCURRENCY=config.get("SUPERSET_CELERY_WORKERS"))
 
     worker = celery_app.Worker(optimization='fair')
-    worker.run()
+    worker.start()
 
 
 @manager.option(