diff --git a/app/celery.py b/app/celery.py index 368d27a..9478bc0 100644 --- a/app/celery.py +++ b/app/celery.py @@ -4,7 +4,7 @@ from celery import Celery os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings') -app = Celery('app') +app = Celery('app', broker_connection_retry_on_startup=True) # Using a string here means the worker doesn't have to serialize # the configuration object to child processes.