Fixed serious error in fxrange introduced today

2011-01-07 13:31:40 +01:00 · 2011-01-07 13:31:40 +01:00 · 4c463808f7
parent 39b1c5c81d
commit 4c463808f7
1 changed files with 2 additions and 3 deletions
--- a/kombu/utils/init.py
+++ b/kombu/utils/init.py
@ -62,12 +62,11 @@ def fxrange(start=1.0, stop=None, step=1.0, repeatlast=False):
    while 1:
        if cur <= stop:
            yield cur
-            if cur + step <= stop:
-                cur += step
+            cur += step
        else:
            if not repeatlast:
                break
-            yield cur
+            yield cur - step


 def retry_over_time(fun, catch, args=[], kwargs={}, errback=None,