Rerun unsuccessful celery tasks indefinitely

wingi11 · web-flow · commit 8ea403849e33 · 2021-04-08T12:14:43.000+02:00
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).
diff --git 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,
 )

Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@`
`16`	`16`	`@shared_task(`
`17`	`17`	`bind=True,`
`18`	`18`	`ignore_results=True,`
	`19`	`+ max_retries=None,`
`19`	`20`	`autoretry_for=(OperationalError,),`
`20`	`21`	`retry_backoff=True,`
`21`	`22`	`)`