diff --git a/src/covid19/blueprints/application/application_workers.py b/src/covid19/blueprints/application/application_workers.py index 9764eefc2038c7e46f1ecb26985b2416e83d1fde..f5c5dd5f7ea5252871446e1555059d5379325d98 100644 --- a/src/covid19/blueprints/application/application_workers.py +++ b/src/covid19/blueprints/application/application_workers.py @@ -32,7 +32,7 @@ def run_app(my_app): my_app.logger.info("# Covid19 Data - WORKER #") my_app.logger.info("#############################################################") my_app.logger.info(" ") - celery_cmd = ['celery', 'worker', '-l', 'INFO'] + celery_cmd = ['celery', '-A', 'app.celery', 'worker', '-l', 'INFO'] subprocess.Popen(celery_cmd, shell=True) my_app.logger.info(" ") my_app.logger.info("#############################################################")