fix(utils): Fix delay issue in Bucket.
This commit is contained in:
@@ -56,7 +56,10 @@ class Bucket:
|
|||||||
def delay(self):
|
def delay(self):
|
||||||
self._leak()
|
self._leak()
|
||||||
if self._level + 1 > self.max_level:
|
if self._level + 1 > self.max_level:
|
||||||
return (self._level + 1 - self.max_level) * self.leak_rate
|
delay = (self._level + 1 - self.max_level) * self.leak_rate
|
||||||
|
else:
|
||||||
|
delay = 0
|
||||||
|
return delay
|
||||||
|
|
||||||
def _leak(self):
|
def _leak(self):
|
||||||
if self._level:
|
if self._level:
|
||||||
|
|||||||
Reference in New Issue
Block a user