[fix] asyncbackoff

mosquito · Dec 25, 2018 · 7486d12 · 7486d12
1 parent aca73c3
commit 7486d12
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/aiomisc/backoff.py b/aiomisc/backoff.py
@@ -40,6 +40,7 @@ def __call__(self, func: T) -> T:
         @wraps(func)
         async def wrap(*args, **kwargs):
             countdown = self.countdown
+            pause = self.pause
 
             while countdown is None or countdown > 0:
                 started_at = monotonic()
@@ -49,13 +50,13 @@ async def wrap(*args, **kwargs):
                     return await func(*args, **kwargs)
                 except self.exceptions:
                     if countdown is not None:
-                        countdown -= monotonic() - started_at + self.pause
+                        countdown -= monotonic() - started_at + pause
 
-                        if self.countdown <= 0:
+                        if countdown <= 0:
                             raise
 
-                    if self.pause > 0:
-                        await asyncio.sleep(self.pause)
+                    if pause > 0:
+                        await asyncio.sleep(pause)
 
                     continue