diff options
Diffstat (limited to 'rq/timeouts.py')
| -rw-r--r-- | rq/timeouts.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/rq/timeouts.py b/rq/timeouts.py index a1401c5..44f01f9 100644 --- a/rq/timeouts.py +++ b/rq/timeouts.py @@ -110,10 +110,14 @@ class TimerDeathPenalty(BaseDeathPenalty): def setup_death_penalty(self): """Starts the timer.""" + if self._timeout <= 0: + return self._timer = self.new_timer() self._timer.start() def cancel_death_penalty(self): """Cancels the timer.""" + if self._timeout <= 0: + return self._timer.cancel() self._timer = None |