Log the act of sending a heartbeat (DEBUG level).

12 years ago · e0866cdc6c
parent e4d37332f0
commit e0866cdc6c
1 changed files with 4 additions and 1 deletions
--- 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):