From 8ea403849e339ab5b6e18d4ae023428c63984f7a Mon Sep 17 00:00:00 2001
From: wingi11 <35778104+wingi11@users.noreply.github.com>
Date: Thu, 8 Apr 2021 12:14:43 +0200
Subject: [PATCH] Rerun unsuccessful celery tasks indefinitely

Change celery tasks config to rerun tasks indefinitely should they fail for an expected reason, like a lock error or because of the tasks return value (conditional gate).
---
 joeflow/runner/celery.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/joeflow/runner/celery.py b/joeflow/runner/celery.py
index 8d6ecfa..a570490 100644
--- a/joeflow/runner/celery.py
+++ b/joeflow/runner/celery.py
@@ -16,6 +16,7 @@
 @shared_task(
     bind=True,
     ignore_results=True,
+    max_retries=None,
     autoretry_for=(OperationalError,),
     retry_backoff=True,
 )