diff options
Diffstat (limited to 'kombu/utils/__init__.py')
| -rw-r--r-- | kombu/utils/__init__.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kombu/utils/__init__.py b/kombu/utils/__init__.py index 8e230afe..b402ff6c 100644 --- a/kombu/utils/__init__.py +++ b/kombu/utils/__init__.py @@ -153,7 +153,6 @@ def retry_over_time(fun, catch, args=[], kwargs={}, errback=None, interval_range = fxrange(interval_start, interval_max + interval_start, interval_step, repeatlast=True) - for retries, interval in enumerate(interval_range): # for infinity try: return fun(*args, **kwargs) @@ -164,10 +163,10 @@ def retry_over_time(fun, catch, args=[], kwargs={}, errback=None, callback() if errback: errback(exc, interval) - for i in fxrange(stop=interval): + for i in fxrange(stop=interval or 1.0): if i and callback: callback() - sleep(1.0) + sleep(i) def emergency_dump_state(state, open_file=open, dump=None): @@ -264,7 +263,7 @@ def reprkwargs(kwargs, sep=', ', fmt='%s=%s'): return sep.join(fmt % (k, _safe_repr(v)) for k, v in kwargs.iteritems()) -def reprcall(name, args=(), kwargs=(), sep=', '): +def reprcall(name, args=(), kwargs={}, sep=', '): return '%s(%s%s%s)' % (name, sep.join(map(_safe_repr, args or ())), (args and kwargs) and sep or '', reprkwargs(kwargs, sep)) |