mirror of https://github.com/rq/rq.git
Change logging format.
This commit is contained in:
parent
8678f26df0
commit
2d2b351f7c
10
rq/worker.py
10
rq/worker.py
|
@ -163,9 +163,9 @@ class Worker(object):
|
||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
self.state = 'idle'
|
self.state = 'idle'
|
||||||
qnames = ', '.join(self.queue_names())
|
qnames = self.queue_names()
|
||||||
self.procline('Waiting on %s' % (qnames,))
|
self.procline('Listening on %s' % (','.join(qnames)))
|
||||||
self.log.info('Waiting for jobs on %s' % (qnames,))
|
self.log.info('*** Listening for work on %s' % (', '.join(qnames)))
|
||||||
wait_for_job = not quit_when_done
|
wait_for_job = not quit_when_done
|
||||||
job = Queue.dequeue_any(self.queues, wait_for_job)
|
job = Queue.dequeue_any(self.queues, wait_for_job)
|
||||||
if job is None:
|
if job is None:
|
||||||
|
@ -213,10 +213,10 @@ class Worker(object):
|
||||||
self.procline('Processing %s from %s since %s' % (
|
self.procline('Processing %s from %s since %s' % (
|
||||||
job.func.__name__,
|
job.func.__name__,
|
||||||
job.origin.name, time.time()))
|
job.origin.name, time.time()))
|
||||||
msg = 'Processing job %s from queue %s' % (
|
msg = 'Got job %s from queue %s' % (
|
||||||
job.call_string,
|
job.call_string,
|
||||||
job.origin.name)
|
job.origin.name)
|
||||||
self.log.debug(msg)
|
self.log.info(msg)
|
||||||
try:
|
try:
|
||||||
rv = job.perform()
|
rv = job.perform()
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
|
|
Loading…
Reference in New Issue