diff --git a/superset/cli.py b/superset/cli.py
index <HASH>..<HASH> 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(
Fix celery worker (#<I>)