diff --git a/src/pretix/api/webhooks.py b/src/pretix/api/webhooks.py index dd6d33335..03800ec04 100644 --- a/src/pretix/api/webhooks.py +++ b/src/pretix/api/webhooks.py @@ -257,7 +257,7 @@ def register_default_webhook_events(sender, **kwargs): ) -@app.task(base=TransactionAwareTask, acks_late=True) +@app.task(base=TransactionAwareTask, max_retries=9, default_retry_delay=900, acks_late=True) def notify_webhooks(logentry_ids: list): if not isinstance(logentry_ids, list): logentry_ids = [logentry_ids] diff --git a/src/pretix/base/services/notifications.py b/src/pretix/base/services/notifications.py index 8c896b695..5583d836f 100644 --- a/src/pretix/base/services/notifications.py +++ b/src/pretix/base/services/notifications.py @@ -13,7 +13,7 @@ from pretix.celery_app import app from pretix.helpers.urls import build_absolute_uri -@app.task(base=TransactionAwareTask, acks_late=True) +@app.task(base=TransactionAwareTask, acks_late=True, max_retries=9, default_retry_delay=900) @scopes_disabled() def notify(logentry_ids: list): if not isinstance(logentry_ids, list): @@ -70,7 +70,7 @@ def notify(logentry_ids: list): send_notification.apply_async(args=(logentry.id, notification_type.action_type, user.pk, method)) -@app.task(base=ProfiledTask, acks_late=True) +@app.task(base=ProfiledTask, acks_late=True, max_retries=9, default_retry_delay=900) def send_notification(logentry_id: int, action_type: str, user_id: int, method: str): logentry = LogEntry.all.get(id=logentry_id) if logentry.event: