From 2d2b351f7cc21aa06de5c89d5a458b827a0368b0 Mon Sep 17 00:00:00 2001 From: Vincent Driessen Date: Mon, 21 Nov 2011 22:41:50 +0100 Subject: [PATCH] Change logging format. --- rq/worker.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/rq/worker.py b/rq/worker.py index e83927d..93e3eed 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -163,9 +163,9 @@ class Worker(object): try: while True: self.state = 'idle' - qnames = ', '.join(self.queue_names()) - self.procline('Waiting on %s' % (qnames,)) - self.log.info('Waiting for jobs on %s' % (qnames,)) + qnames = self.queue_names() + self.procline('Listening on %s' % (','.join(qnames))) + self.log.info('*** Listening for work on %s' % (', '.join(qnames))) wait_for_job = not quit_when_done job = Queue.dequeue_any(self.queues, wait_for_job) if job is None: @@ -213,10 +213,10 @@ class Worker(object): self.procline('Processing %s from %s since %s' % ( job.func.__name__, job.origin.name, time.time())) - msg = 'Processing job %s from queue %s' % ( + msg = 'Got job %s from queue %s' % ( job.call_string, job.origin.name) - self.log.debug(msg) + self.log.info(msg) try: rv = job.perform() except Exception, e: