Do not wait on the first DB serialization failure

epandurski · Jul 29, 2019 · 6300de5 · 6300de5
1 parent 0b40bbe
commit 6300de5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flask_signalbus/utils.py b/flask_signalbus/utils.py
@@ -46,8 +46,9 @@ def f(*args, **kwargs):
                     if num_failures > retries or not is_serialization_error:
                         raise
                 session.rollback()
-                wait_seconds = min(max_wait, min_wait * 2 ** (num_failures - 1))
-                time.sleep(wait_seconds)
+                if num_failures > 1:
+                    wait_seconds = min(max_wait, min_wait * 2 ** (num_failures - 2))
+                    time.sleep(wait_seconds)
 
         return f