From e0866cdc6c4449c30534080aac5a2444321294ca Mon Sep 17 00:00:00 2001 From: Vincent Driessen Date: Fri, 15 Feb 2013 08:50:13 +0100 Subject: [PATCH] Log the act of sending a heartbeat (DEBUG level). --- rq/worker.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index 4dd2874..b11bec9 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -343,7 +343,10 @@ class Worker(object): return Queue.dequeue_any(self.queues, timeout, connection=self.connection) except DequeueTimeout: - self.connection.expire(self.key, self.default_worker_ttl) + pass + + self.log.debug('Sending heartbeat to prevent worker timeout.') + self.connection.expire(self.key, self.default_worker_ttl) def fork_and_perform_job(self, job):