summaryrefslogtreecommitdiff
path: root/retrying.py
diff options
context:
space:
mode:
authorDaniel Nephin <dnephin@yelp.com>2014-08-22 07:31:21 -0700
committerDaniel Nephin <dnephin@yelp.com>2014-08-22 07:31:21 -0700
commit8b73aff04ee320ce27570c447028c30817f23d1a (patch)
tree50eb19a37aebe4c114a3a26e040feecc08de8577 /retrying.py
parent6d8ef5bd03365836910edcd3398331ab22b17c00 (diff)
downloadretrying-8b73aff04ee320ce27570c447028c30817f23d1a.tar.gz
Support custom wait and stop functions.
Diffstat (limited to 'retrying.py')
-rw-r--r--retrying.py14
1 files changed, 11 insertions, 3 deletions
diff --git a/retrying.py b/retrying.py
index ccf9668..50fc439 100644
--- a/retrying.py
+++ b/retrying.py
@@ -108,7 +108,9 @@ class Retrying(object):
wait_exponential_multiplier=None, wait_exponential_max=None,
retry_on_exception=None,
retry_on_result=None,
- wrap_exception=False):
+ wrap_exception=False,
+ stop_func=None,
+ wait_func=None):
self._stop_max_attempt_number = 5 if stop_max_attempt_number is None else stop_max_attempt_number
self._stop_max_delay = 100 if stop_max_delay is None else stop_max_delay
@@ -129,7 +131,10 @@ class Retrying(object):
if stop_max_delay is not None:
stop_funcs.append(self.stop_after_delay)
- if stop is None:
+ if stop_func is not None:
+ self.stop = stop_func
+
+ elif stop is None:
self.stop = lambda attempts, delay: any(f(attempts, delay) for f in stop_funcs)
else:
@@ -150,7 +155,10 @@ class Retrying(object):
if wait_exponential_multiplier is not None or wait_exponential_max is not None:
wait_funcs.append(self.exponential_sleep)
- if wait is None:
+ if wait_func is not None:
+ self.wait = wait_func
+
+ elif wait is None:
self.wait = lambda attempts, delay: max(f(attempts, delay) for f in wait_funcs)
else: