diff --git a/oslo_messaging/_drivers/common.py b/oslo_messaging/_drivers/common.py index b2d97b37c..89ad0660e 100644 --- a/oslo_messaging/_drivers/common.py +++ b/oslo_messaging/_drivers/common.py @@ -345,7 +345,7 @@ class DecayingTimer(object): maximum = kwargs.pop('maximum', None) if self._duration is None: - return None if maximum is None else maximum + return maximum if self._ends_at is None: raise RuntimeError(_("Can not check/return a timeout from a timer" " that has not been started."))