diff --git a/CHANGES.md b/CHANGES.md index f4943a9..d8e39f3 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -19,6 +19,13 @@ - Fix: `Queue.empty()` now correctly deletes job hashes from Redis. +### 0.3.13 +(December 17th, 2013) + +- Bug fix where the worker crashes on jobs that have their timeout explicitly + removed. Thanks for reporting, @algrs. + + ### 0.3.12 (December 16th, 2013) diff --git a/rq/version.py b/rq/version.py index 3b59d7f..954b701 100644 --- a/rq/version.py +++ b/rq/version.py @@ -1 +1 @@ -VERSION = '0.3.12' +VERSION = '0.3.13' diff --git a/rq/worker.py b/rq/worker.py index 6a56da0..b517b85 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -322,7 +322,7 @@ class Worker(object): self.log.info('%s: %s (%s)' % (green(queue.name), blue(job.description), job.id)) - self.heartbeat((job.timeout or Queue.DEFAULT_TIMEOUT) + 60) + self.heartbeat((job.timeout or 180) + 60) self.fork_and_perform_job(job) self.heartbeat() if job.status == Status.FINISHED: