Skip to content

Commit c7640eb

Browse files
committed
feat: add before_sleep as constructor arg to RetryStrategy.
1 parent 73244ae commit c7640eb

1 file changed

Lines changed: 10 additions & 3 deletions

File tree

src/sumo/wrapper/_retry_strategy.py

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,10 +38,17 @@ def _return_last_value(retry_state):
3838

3939

4040
class RetryStrategy:
41-
def __init__(self, stop_after=6, multiplier=0.5, exp_base=2):
41+
def __init__(
42+
self,
43+
stop_after=6,
44+
multiplier=0.5,
45+
exp_base=2,
46+
before_sleep=_log_retry_info,
47+
):
4248
self._stop_after = stop_after
4349
self._multiplier = multiplier
4450
self._exp_base = exp_base
51+
self._before_sleep = before_sleep
4552
return
4653

4754
def make_retryer(self) -> tn.Retrying:
@@ -60,7 +67,7 @@ def make_retryer(self) -> tn.Retrying:
6067
)
6168
),
6269
retry_error_callback=_return_last_value,
63-
before_sleep=_log_retry_info,
70+
before_sleep=self._before_sleep,
6471
)
6572

6673
def make_retryer_async(self) -> tn.AsyncRetrying:
@@ -79,5 +86,5 @@ def make_retryer_async(self) -> tn.AsyncRetrying:
7986
)
8087
),
8188
retry_error_callback=_return_last_value,
82-
before_sleep=_log_retry_info,
89+
before_sleep=self._before_sleep,
8390
)

0 commit comments

Comments
 (0)