Add extra options as recommended in deprecation warnings

ibutsu · Jun 21, 2023 · c71f4d4 · c71f4d4
1 parent 4dfc45d
commit c71f4d4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backend/ibutsu_server/tasks/__init__.py b/backend/ibutsu_server/tasks/__init__.py
@@ -71,6 +71,9 @@ def on_failure(self, exc, task_id, args, kwargs, einfo):
     app = Celery(
         "ibutsu_server",
         broker=_app.config.get("CELERY_BROKER_URL"),
+        broker_connection_retry=True,
+        broker_connection_retry_on_startup=True,
+        worker_cancel_long_running_tasks_on_connection_loss=True,
         include=[
             "ibutsu_server.tasks.db",
             "ibutsu_server.tasks.importers",